Struct zeromq::PullSocket

pub struct PullSocket { /* private fields */ }

Trait Implementations

impl Socket for PullSocket

fn with_options(options: SocketOptions) -> Self

fn backend(&self) -> Arc<dyn MultiPeerBackend>

fn binds(&mut self) -> &mut HashMap<Endpoint, AcceptStopHandle, RandomState>

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

Creates and setups new socket monitor

fn new() -> Self

fn bind<'life0, 'life1, 'async_trait>( &'life0 mut self, endpoint: &'life1 str ) -> Pin<Box<dyn Future<Output = ZmqResult<Endpoint>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

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

fn unbind<'life0, 'async_trait>( &'life0 mut self, endpoint: Endpoint ) -> Pin<Box<dyn Future<Output = ZmqResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Unbinds the endpoint, blocking until the associated endpoint is no longer in use

fn unbind_all<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Vec<ZmqError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Unbinds all bound endpoints, blocking until finished.

fn connect<'life0, 'life1, 'async_trait>( &'life0 mut self, endpoint: &'life1 str ) -> Pin<Box<dyn Future<Output = ZmqResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Connects to the given endpoint.

fn close<'async_trait>( self ) -> Pin<Box<dyn Future<Output = Vec<ZmqError>> + Send + 'async_trait>>

where Self: 'async_trait,

Disconnects from the given endpoint, blocking until finished.

impl SocketRecv for PullSocket

fn recv<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = ZmqResult<ZmqMessage>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,