pub struct TcpIncomingConnection { /* private fields */ }Expand description
A TCP connection accepted by TokioTcp::bind.
Plain TCP is the only transport in WP-12b; TLS and UDP are intentionally
deferred. The connection can be consumed as independent byte source/sink
halves or as a coupled Flow<Vec<u8>, Vec<u8>>.
Implementations§
Source§impl TcpIncomingConnection
impl TcpIncomingConnection
pub fn local_addr(&self) -> SocketAddr
pub fn remote_addr(&self) -> SocketAddr
pub fn connection(&self) -> TcpConnection
pub fn into_parts(self) -> (TokioByteSource, TokioByteSink)
pub fn into_flow(self) -> Flow<Vec<u8>, Vec<u8>, NotUsed>
Auto Trait Implementations§
impl !RefUnwindSafe for TcpIncomingConnection
impl !UnwindSafe for TcpIncomingConnection
impl Freeze for TcpIncomingConnection
impl Send for TcpIncomingConnection
impl Sync for TcpIncomingConnection
impl Unpin for TcpIncomingConnection
impl UnsafeUnpin for TcpIncomingConnection
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<T> Message for T
impl<T> Message for T
Source§fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>
fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>
Convert a BoxedMessage to this concrete type
Source§fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>
fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>
Convert this message to a BoxedMessage