Package org.consensusj.rx.zeromq

Class ZMsgSocketFlowable

java.lang.Object

org.consensusj.rx.zeromq.ZMsgSocketFlowable

public class ZMsgSocketFlowable
extends Object

Factory class for creating Publisher<ZMsg> from a ZMQ.Socket. The created Publisher will receive a multiplexed stream of ZMsg (i.e. ZMsg for all topics.) Typically these multiplexed Publisher<ZMsg> are created by a RxZmqContext which also de-multiplexes them.

TODO: Write some tests!!

Constructor Summary

Constructors

Constructor	Description
ZMsgSocketFlowable()

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ZMsgSocketFlowable

public ZMsgSocketFlowable()