Struct WsConn

pub struct WsConn<C> {
    read_stream: Mutex<ReadWsStream<C>>,
    write_stream: Mutex<WriteWsStream<C>>,
    peer_endpoint: Endpoint,
    local_endpoint: Endpoint,
}

WS network connection implementation of the Connection trait.

Fields

read_stream: Mutex<ReadWsStream<C>>

write_stream: Mutex<WriteWsStream<C>>

peer_endpoint: Endpoint

local_endpoint: Endpoint

Implementations

impl<C> WsConn<C>

where C: WebSocketCodec + Clone,

pub fn new( ws: WsStream<C>, peer_endpoint: Endpoint, local_endpoint: Endpoint, ) -> Self

Creates a new WsConn

Trait Implementations

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

where C: WebSocketCodec<Error = E>, E: From<Error>,

type Message = <C as WebSocketCodec>::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 WsConn<C>

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

type Message = <C as WebSocketCodec>::Message

type Error = E

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