pub struct TcpIncomingConnection { /* private fields */ }Expand description
A TCP connection accepted by TokioTcp::bind.
TokioTcp carries plain TCP only; TLS, UDP, and QUIC live in the datum-net satellite crate.
The connection can be consumed as independent byte source/sink halves
(into_parts) or as a coupled
Flow<Vec<u8>, Vec<u8>> (into_flow).
Implementations§
Source§impl TcpIncomingConnection
impl TcpIncomingConnection
pub fn local_addr(&self) -> SocketAddr
pub fn remote_addr(&self) -> SocketAddr
pub fn connection(&self) -> TcpConnection
Sourcepub fn into_parts(self) -> (TokioByteSource, TokioByteSink)
pub fn into_parts(self) -> (TokioByteSource, TokioByteSink)
Splits the connection into independent read (TokioByteSource) and write
(TokioByteSink) halves. The halves are decoupled: completing the write half
(TCP FIN) does not tear down the read half.
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