Struct UnixConn

pub struct UnixConn<C> {
    read_stream: Mutex<ReadStream<ReadHalf<UnixStream>, C>>,
    write_stream: Mutex<WriteStream<WriteHalf<UnixStream>, C>>,
    peer_endpoint: Option<Endpoint>,
    local_endpoint: Option<Endpoint>,
}

Unix domain socket implementation of the Connection trait.

Fields

read_stream: Mutex<ReadStream<ReadHalf<UnixStream>, C>>

write_stream: Mutex<WriteStream<WriteHalf<UnixStream>, C>>

peer_endpoint: Option<Endpoint>

local_endpoint: Option<Endpoint>

Implementations

impl<C> UnixConn<C>

where C: Codec + Clone,

pub fn new(conn: UnixStream, codec: C) -> Self

Creates a new TcpConn

Trait Implementations

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

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

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 UnixConn<C>

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

type Message = <C as Codec>::Message

type Error = E

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