Struct PushSocket

pub struct PushSocket { /* private fields */ }

Trait Implementations

impl Drop for PushSocket

fn drop(&mut self)

Executes the destructor for this type.

impl Socket for PushSocket

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 SocketSend for PushSocket

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

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

impl CaptureSocket for PushSocket