Struct PushSocket 

pub struct PushSocket { /* private fields */ }

Push socket (PUSH). Distributes messages round-robin to connected PULL peers.

Use with PullSocket to build a pipeline. Each message goes to exactly one peer.

See RFC 30 for the PUSH/PULL wire contract and zmq_socket(3).

Trait Implementations

impl Socket for PushSocket

type Backend = GenericSocketBackend

fn with_options(options: SocketOptions) -> Self

Create a socket with the given options.

async fn connect<E>(&mut self, endpoint: E) -> ZmqResult<()>

where E: TryInto<Endpoint> + Send, E::Error: Into<ZmqError>,

Connects to the given endpoint.

fn new() -> Self

Create a socket with default options.

fn builder() -> SocketBuilder<Self>

Create a SocketBuilder to configure the socket before constructing it.

fn bind<E>( &mut self, endpoint: E, ) -> impl Future<Output = ZmqResult<Endpoint>> + Send

where E: TryInto<Endpoint> + Send, E::Error: Into<ZmqError>,

Binds to the endpoint and starts a coroutine to accept new connections on it. Returns the resolved bound endpoint.

fn last_endpoint(&self) -> Option<&Endpoint>

Returns the last endpoint resolved by bind, or None if the socket has not been bound.

fn unbind( &mut self, endpoint: Endpoint, ) -> impl Future<Output = ZmqResult<()>> + Send

Stop accepting connections on the given endpoint.

fn unbind_all(&mut self) -> impl Future<Output = Vec<ZmqError>> + Send

Stop accepting connections on all bound endpoints.

fn monitor(&mut self) -> Receiver<SocketEvent>

Subscribe to SocketEvents. Returns a channel receiver that yields events as connections are made, accepted, or dropped.

fn close(self) -> impl Future<Output = Result<(), Vec<ZmqError>>> + Send

Stop accepting connections and wait for outbound messages to drain (subject to the configured linger timeout), then drop the socket.

impl SocketSend for PushSocket

async fn send(&mut self, message: impl Into<ZmqMessage> + Send) -> ZmqResult<()>

Send a message, blocking until it is accepted by the outbound queue.

impl CaptureSocket for PushSocket