Struct Tcp 

pub struct Tcp { /* private fields */ }

Implementations

impl Tcp

pub fn new(config: Config) -> Self

Trait Implementations

impl Debug for Tcp

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for Tcp

fn default() -> Tcp

Returns the “default value” for a type.

impl Transport<SocketAddr> for Tcp

type Stats = TcpStats

The statistics for the transport (specifically its underlying IO object).

type Io = TcpStream

The result of a successful connection.

type Control = ()

Control-plane messages that modify the runtime behavior of the transport.

type Error = Error

An error that occurred when setting up the connection.

type Connect = Pin<Box<dyn Future<Output = Result<<Tcp as Transport<SocketAddr>>::Io, <Tcp as Transport<SocketAddr>>::Error>> + Send>>

A pending output for an outbound connection, obtained when calling Transport::connect.

type Accept = Pin<Box<dyn Future<Output = Result<<Tcp as Transport<SocketAddr>>::Io, <Tcp as Transport<SocketAddr>>::Error>> + Send>>

A pending output for an inbound connection, obtained when calling Transport::poll_accept.

fn local_addr(&self) -> Option<SocketAddr>

Returns the local address this transport is bound to (if it is bound).

fn bind<'life0, 'async_trait>( &'life0 mut self, addr: SocketAddr, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Binds to the given address.

fn connect(&mut self, addr: SocketAddr) -> Self::Connect

Connects to the given address, returning a future representing a pending outbound connection.

fn poll_accept(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Accept>

Poll for incoming connections. If an inbound connection is received, a future representing a pending inbound connection is returned. The future will resolve to Transport::Accept.

fn on_control(&mut self, _ctrl: Self::Control)

Applies a control-plane message to the transport. It is expected to update internal state only and should not perform long-running operations.

impl TransportExt<SocketAddr> for Tcp

fn accept(&mut self) -> Acceptor<'_, Self, SocketAddr>

where Self: Sized + Unpin,

Async-friendly interface for accepting inbound connections.