Package org.consensusj.rx.zeromq

package org.consensusj.rx.zeromq
Reactive interface to ZeroMQ using JeroMQ library. Reactive streams are available via the Publisher interface, but this will change to Flow.Publisher before the 1.0 release. It is currently implemented internally with RxJava 3. Use RxZmqContext to connect to a server and subscribe to a List of topics.
  • Classes
    Class
    Description
    RxZmqContext
    ZMQ Context with a single socket and one Processor<ZMsg> per topic.
    ZMsgSocketFlowable
    Factory class for creating Publisher<ZMsg> from a ZMQ.Socket.