Struct ntex::framed::Read

pub struct Read<'a>(_);

Implementations

impl<'a> Read<'a>

pub fn is_ready(&self) -> bool

Check if read buffer has new data

pub fn is_full(&self) -> bool

Check if read buffer is full

pub fn pause(&self, waker: &Waker)

Pause read task

Also register dispatch task

pub fn resume(&self) -> bool

Wake read io task if it is paused

pub fn wake(&self, waker: &Waker)

Wake read task and instruct to read more data

Only wakes if back-pressure is enabled on read task otherwise read is already awake.

pub fn decode<U>(
    &self,
    codec: &U
) -> Result<Option<<U as Decoder>::Item>, <U as Decoder>::Error> where
    U: Decoder, 

Attempts to decode a frame from the read buffer.

pub fn with_buf<F, R>(&self, f: F) -> R where
    F: FnOnce(&mut BytesMut) -> R, 

Get mut access to read buffer

Trait Implementations

impl<'a> Clone for Read<'a>

fn clone(&self) -> Read<'a>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<'a> Copy for Read<'a>