Crate bitcoincore_zmq
source ·Modules§
Structs§
- MessageStream
async
Stream returned bysubscribe_async
. - A
SocketEvent
combined with its source (the url used when connecting). - Stream that asynchronously produces
Message
s using multiple ZMQ subscribers. The ZMQ sockets are polled in a round-robin fashion.
Enums§
- Possible values for the ZMQ_EVENT_HANDSHAKE_FAILED_PROTOCOL 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. - SocketMessage
async
AMessage
or aMonitorMessage
.
Constants§
Functions§
- subscribe_async
async
Subscribes to multiple ZMQ endpoints and returns a stream that producesMessage
s. - Subscribes to multiple ZMQ endpoints and returns a stream that yields
Message
s and events (seeMonitorMessage
). - Subscribes to multiple ZMQ endpoints and returns a stream that yields
Message
s and events (seeMonitorMessage
). This method will wait until a connection has been established to all endpoints. - See
subscribe_async_wait_handshake
. This method implements the inefficient, but runtime independent approach. - Subscribes to multiple ZMQ endpoints and blocks the thread until
ControlFlow::Break
is returned by the callback. - subscribe_multiDeprecatedSubscribes to multiple ZMQ endpoints and returns a
Receiver
. - Subscribes to multiple ZMQ endpoints and returns a
MultiMessageStream
. - subscribe_multi_blockingDeprecatedSubscribes to multiple ZMQ endpoints and blocks the thread until
ControlFlow::Break
is returned by the callback. - Subscribes to multiple ZMQ endpoints and returns a
Receiver
. - subscribe_singleDeprecatedSubscribes to a single ZMQ endpoint and returns a
Receiver
. - Subscribes to a single ZMQ endpoint and returns a
MessageStream
. - subscribe_single_blockingDeprecatedSubscribes to a single ZMQ endpoint and blocks the thread until
ControlFlow::Break
is returned by the callback.