Struct async_streamdata::reader::tokio::BytesReader

pub struct BytesReader<T> {
    pub inner: T,
    pub buf: BytesMut,
}

A reader with an internal buffer of bytes::BytesMut.

Fields

inner: T

The inner reader.

buf: BytesMut

The buffer to use for reading the data.

Trait Implementations

impl<T: Debug> Debug for BytesReader<T>

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

Formats the value using the given formatter.

impl<T> Reader for BytesReader<T>where T: AsyncRead + Unpin,

type Data<'data> = &'data [u8]

The chunk data.

type Error = Error

The error that can originate at the reader.

async fn next(&mut self) -> Option<Result<Self::Data<'_>, Self::Error>>

Read next chunk of data. If there is no more data to read - returns None.