Modules§
Structs§
- Message
Stream async - Stream returned by
subscribe_async. - Monitor
Message - A
SocketEventcombined with its source (the url used when connecting). - Multi
Message Stream Deprecated async - Stream that asynchronously produces
Messages using multiple ZMQ subscribers. The ZMQ sockets are polled in a round-robin fashion.
Enums§
- Error
- Handshake
Failure - Possible values for the ZMQ_EVENT_HANDSHAKE_FAILED_PROTOCOL socket event.
- Message
- Sequence
Message - Socket
Event - An event from one of the connected sockets. See the “SUPPORTED EVENTS” section in the
“zmq_socket_monitor” manual page (
man zmq_socket_monitor) for the original documentation. - Socket
Message async - A
Messageor aMonitorMessage.
Constants§
Functions§
- subscribe_
async async - Subscribes to multiple ZMQ endpoints and returns a stream that produces
Messages. - subscribe_
async_ monitor async - Subscribes to multiple ZMQ endpoints and returns a stream that yields
Messages and events (seeMonitorMessage). - subscribe_
async_ wait_ handshake async - Subscribes to multiple ZMQ endpoints and returns a stream that yields
Messages and events (seeMonitorMessage). This method will wait until a connection has been established to all endpoints. - subscribe_
async_ wait_ handshake_ timeout async - See
subscribe_async_wait_handshake. This method implements the inefficient, but runtime independent approach. - subscribe_
blocking - Subscribes to multiple ZMQ endpoints and blocks the thread until
ControlFlow::Breakis returned by the callback. - subscribe_
multi Deprecated - Subscribes to multiple ZMQ endpoints and returns a
Receiver. - subscribe_
multi_ async Deprecated async - Subscribes to multiple ZMQ endpoints and returns a
MultiMessageStream. - subscribe_
multi_ blocking Deprecated - Subscribes to multiple ZMQ endpoints and blocks the thread until
ControlFlow::Breakis returned by the callback. - subscribe_
receiver - Subscribes to multiple ZMQ endpoints and returns a
Receiver. - subscribe_
single Deprecated - Subscribes to a single ZMQ endpoint and returns a
Receiver. - subscribe_
single_ async Deprecated async - Subscribes to a single ZMQ endpoint and returns a
MessageStream. - subscribe_
single_ blocking Deprecated - Subscribes to a single ZMQ endpoint and blocks the thread until
ControlFlow::Breakis returned by the callback.