Struct XPubSocket 

pub struct XPubSocket { /* private fields */ }

Trait Implementations

impl Drop for XPubSocket

fn drop(&mut self)

Executes the destructor for this type.

impl Socket for XPubSocket

fn with_options(options: SocketOptions) -> Self

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

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

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 XPubSocket

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,

impl SocketSend for XPubSocket

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 XPubSocket