Struct FrameReader 

pub struct FrameReader<R> { /* private fields */ }

Async frame reader over any AsyncRead stream.

Buffers incoming bytes and yields complete Frames.

Implementations

impl<R: AsyncRead + Unpin> FrameReader<R>

pub fn new(inner: R) -> Self

Wrap a reader.

pub async fn read_frame(&mut self) -> Result<Option<Frame>, TransportError>

Read the next frame. Returns None on clean EOF.

pub fn inner(&self) -> &R

Get a reference to the inner reader.

pub fn into_inner(self) -> R

Consume the reader and return the inner stream.

Trait Implementations

impl<R: Debug> Debug for FrameReader<R>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.