pub struct CompositeTcpListener { /* private fields */ }
Implementations§
Trait Implementations§
Source§impl Debug for CompositeTcpListener
impl Debug for CompositeTcpListener
Source§impl Default for CompositeTcpListener
impl Default for CompositeTcpListener
Source§impl VirtualIoSource for CompositeTcpListener
impl VirtualIoSource for CompositeTcpListener
Source§fn remove_handler(&mut self)
fn remove_handler(&mut self)
Removes a previously registered waker using a token
Source§impl VirtualTcpListener for CompositeTcpListener
impl VirtualTcpListener for CompositeTcpListener
Source§fn try_accept(
&mut self,
) -> Result<(Box<dyn VirtualTcpSocket + Sync>, SocketAddr)>
fn try_accept( &mut self, ) -> Result<(Box<dyn VirtualTcpSocket + Sync>, SocketAddr)>
Tries to accept a new connection
Source§fn set_handler(
&mut self,
handler: Box<dyn InterestHandler + Send + Sync>,
) -> Result<()>
fn set_handler( &mut self, handler: Box<dyn InterestHandler + Send + Sync>, ) -> Result<()>
Registers a waker for when a new connection has arrived. This uses
a stack machine which means more than one waker can be registered
Source§fn addr_local(&self) -> Result<SocketAddr>
fn addr_local(&self) -> Result<SocketAddr>
Returns the local address of this TCP listener
Auto Trait Implementations§
impl Freeze for CompositeTcpListener
impl !RefUnwindSafe for CompositeTcpListener
impl Send for CompositeTcpListener
impl Sync for CompositeTcpListener
impl Unpin for CompositeTcpListener
impl !UnwindSafe for CompositeTcpListener
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
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<R> VirtualTcpListenerExt for Rwhere
R: VirtualTcpListener + ?Sized,
impl<R> VirtualTcpListenerExt for Rwhere
R: VirtualTcpListener + ?Sized,
Source§fn accept<'life0, 'async_trait>(
&'life0 mut self,
) -> Pin<Box<dyn Future<Output = Result<(Box<dyn VirtualTcpSocket + Sync>, SocketAddr), NetworkError>> + Send + 'async_trait>>where
'life0: 'async_trait,
R: 'async_trait,
fn accept<'life0, 'async_trait>(
&'life0 mut self,
) -> Pin<Box<dyn Future<Output = Result<(Box<dyn VirtualTcpSocket + Sync>, SocketAddr), NetworkError>> + Send + 'async_trait>>where
'life0: 'async_trait,
R: 'async_trait,
Accepts a new connection from the TCP listener