Crate bitcoincore_zmq

Modules

subscribe_async_monitor_streamasync

subscribe_async_streamasync

Structs

MessageStreamasync

Stream returned by subscribe_async.

MonitorMessage

A SocketEvent combined with its source (the url used when connecting).

MultiMessageStreamDeprecatedasync

Stream that asynchronously produces Messages using multiple ZMQ subscribers. The ZMQ sockets are polled in a round-robin fashion.

Enums

Error

HandshakeFailure

Possible values for the ZMQ_EVENT_HANDSHAKE_FAILED_PROTOCOL socket event.

Message

SequenceMessage

SocketEvent

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.

SocketMessageasync

A Message or a MonitorMessage.

Constants

DATA_MAX_LEN

SEQUENCE_LEN

TOPIC_MAX_LEN

Functions

subscribe_asyncasync

Subscribes to multiple ZMQ endpoints and returns a stream that produces Messages.

subscribe_async_monitorasync

Subscribes to multiple ZMQ endpoints and returns a stream that yields Messages and events (see MonitorMessage).

subscribe_async_wait_handshakeasync

Subscribes to multiple ZMQ endpoints and returns a stream that yields Messages and events (see MonitorMessage). This method will wait until a connection has been established to all endpoints.

subscribe_async_wait_handshake_timeoutasync

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::Break is returned by the callback.

subscribe_multiDeprecated

Subscribes to multiple ZMQ endpoints and returns a Receiver.

subscribe_multi_asyncDeprecatedasync

Subscribes to multiple ZMQ endpoints and returns a MultiMessageStream.

subscribe_multi_blockingDeprecated

Subscribes to multiple ZMQ endpoints and blocks the thread until ControlFlow::Break is returned by the callback.

subscribe_receiver

Subscribes to multiple ZMQ endpoints and returns a Receiver.

subscribe_singleDeprecated

Subscribes to a single ZMQ endpoint and returns a Receiver.

subscribe_single_asyncDeprecatedasync

Subscribes to a single ZMQ endpoint and returns a MessageStream.

subscribe_single_blockingDeprecated

Subscribes to a single ZMQ endpoint and blocks the thread until ControlFlow::Break is returned by the callback.