Struct TlsConn

pub struct TlsConn<C> {
    read_stream: Mutex<ReadStream<ReadHalf<TlsStream<TcpStream>>, C>>,
    write_stream: Mutex<WriteStream<WriteHalf<TlsStream<TcpStream>>, C>>,
    peer_endpoint: Endpoint,
    local_endpoint: Endpoint,
}

TLS network connection implementation of the Connection trait.

Fields

read_stream: Mutex<ReadStream<ReadHalf<TlsStream<TcpStream>>, C>>

write_stream: Mutex<WriteStream<WriteHalf<TlsStream<TcpStream>>, C>>

peer_endpoint: Endpoint

local_endpoint: Endpoint

Implementations

impl<C> TlsConn<C>

where C: Codec + Clone,

pub fn new( conn: TlsStream<TcpStream>, codec: C, peer_endpoint: Endpoint, local_endpoint: Endpoint, ) -> Self

Creates a new TlsConn

Trait Implementations

impl<C, E> Connection for TlsConn<C>

where C: Clone + Codec<Error = E>,

type Message = <C as Codec>::Message

type Error = E

fn peer_endpoint(&self) -> Result<Endpoint, Self::Error>

Returns the remote peer endpoint of this connection

fn local_endpoint(&self) -> Result<Endpoint, Self::Error>

Returns the local socket endpoint of this connection

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

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

Recvs data from this connection.

fn send<'life0, 'async_trait>( &'life0 self, msg: Self::Message, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

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

Sends data to this connection

impl<C, E> ToConn for TlsConn<C>

where C: Codec<Error = E> + Clone + 'static,

type Message = <C as Codec>::Message

type Error = E

fn to_conn(self) -> Conn<Self::Message, Self::Error>