Struct zeromq::RouterSocket

pub struct RouterSocket { /* fields omitted */ }

Trait Implementations

impl Drop for RouterSocket

fn drop(&mut self)

Executes the destructor for this type.

impl Socket for RouterSocket

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
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: '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
    'life0: 'async_trait,
    Self: '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
    'life0: 'async_trait,
    Self: '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
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: '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 RouterSocket

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

impl SocketSend for RouterSocket

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