Trait MessageRx 

pub trait MessageRx: Send + Sync {
    type Message: Send + Sync;

    // Required methods
    fn recv_msg(&mut self) -> impl Future<Output = Result<Self::Message>> + Send;
    fn peer_endpoint(&self) -> Option<Endpoint>;
}

Read half of a message connection.

Required Associated Types

type Message: Send + Sync

Required Methods

fn recv_msg(&mut self) -> impl Future<Output = Result<Self::Message>> + Send

Receive one complete message.

fn peer_endpoint(&self) -> Option<Endpoint>

Remote peer address.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

impl<C> MessageRx for WsReader<C>

where C: Codec<Message> + Send + Sync, C::Message: Send + Sync, C::Error: From<Error> + Into<Error> + Send + Sync,

type Message = <C as Codec<Message>>::Message

impl<C> MessageRx for FramedReader<C>

where C: Codec<ByteBuffer> + Send + Sync, C::Message: Send + Sync, C::Error: From<Error> + Into<Error> + Send + Sync,

type Message = <C as Codec<Buffer>>::Message