Struct zeromq::RouterSocket
source · pub struct RouterSocket { /* private fields */ }
Trait Implementations§
source§impl Drop for RouterSocket
impl Drop for RouterSocket
source§impl Socket for RouterSocket
impl Socket for RouterSocket
fn with_options(options: SocketOptions) -> Self
fn backend(&self) -> Arc<dyn MultiPeerBackend>
fn binds(&mut self) -> &mut HashMap<Endpoint, AcceptStopHandle>
source§fn monitor(&mut self) -> Receiver<SocketEvent>
fn monitor(&mut self) -> Receiver<SocketEvent>
Creates and setups new socket monitor Read more
fn new() -> Self
source§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,
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. Read more
source§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,
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 Read more
source§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,
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.
source§impl SocketRecv for RouterSocket
impl SocketRecv for RouterSocket
source§impl SocketSend for RouterSocket
impl SocketSend for RouterSocket
Auto Trait Implementations§
impl !RefUnwindSafe for RouterSocket
impl Send for RouterSocket
impl Sync for RouterSocket
impl Unpin for RouterSocket
impl !UnwindSafe for RouterSocket
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more