Struct TcpTransport 

pub struct TcpTransport {
    pub socket_opts: SocketOpts,
    pub cfg: TcpConfig,
}

Fields

socket_opts: SocketOpts

cfg: TcpConfig

Trait Implementations

impl Debug for TcpTransport

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

Formats the value using the given formatter.

impl Transport for TcpTransport

type Acceptor = Listener

type Stream = TcpStream

type RawStream = Stream

fn new(config: &TransportConfig) -> Result<Self>

fn as_raw_fd(conn: &Self::Stream) -> RawFd

Get the stream id, which is used to identify the transport layer

fn hint(conn: &Self::Stream, opt: SocketOpts)

Provide the transport with socket options, which can be handled at the need of the transport

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

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

fn accept<'life0, 'life1, 'async_trait>( &'life0 self, a: &'life1 Self::Acceptor, ) -> Pin<Box<dyn Future<Output = Result<(Self::RawStream, SocketAddr)>> + Send + 'async_trait>>

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

accept must be cancel safe

fn handshake<'life0, 'async_trait>( &'life0 self, conn: Self::RawStream, ) -> Pin<Box<dyn Future<Output = Result<Self::Stream>> + Send + 'async_trait>>

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

fn connect<'life0, 'life1, 'async_trait>( &'life0 self, addr: &'life1 AddrMaybeCached, ) -> Pin<Box<dyn Future<Output = Result<Self::Stream>> + Send + 'async_trait>>

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

fn get_header(&self, _name: &str) -> Option<String>