Struct FramedReader 

pub struct FramedReader<C> {
    inner: ReadHalf<Box<dyn ByteStream>>,
    decoder: C,
    buffer: ByteBuffer,
    read_chunk_size: usize,
    peer_endpoint: Option<Endpoint>,
    local_endpoint: Option<Endpoint>,
}

Read half of a framed connection.

Fields

inner: ReadHalf<Box<dyn ByteStream>>

decoder: C

buffer: ByteBuffer

read_chunk_size: usize

peer_endpoint: Option<Endpoint>

local_endpoint: Option<Endpoint>

Implementations

impl<C> FramedReader<C>

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

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

Remote peer address.

pub fn local_endpoint(&self) -> Option<Endpoint>

Local address.

pub async fn recv_msg(&mut self) -> Result<C::Message>

Receive one complete message.

Trait Implementations

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

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.