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