Struct async_streamdata::reader::generic::Reader

pub struct Reader<IoImplementation, Inner, EofCondition, Buffer> {
    pub inner: Inner,
    pub buf: Buffer,
    pub phantom_data: PhantomData<(EofCondition, IoImplementation)>,
}

A reader with an internal buffer.

Fields

inner: Inner

The inner reader.

buf: Buffer

The buffer to use for reading the data.

phantom_data: PhantomData<(EofCondition, IoImplementation)>

The phantom data for tracking the generic parameters that are not used directly in the struct definition.

Implementations

impl<IoImplementation, Inner, EofCondition, Buffer> Reader<IoImplementation, Inner, EofCondition, Buffer>

pub fn new(inner: Inner, buf: Buffer) -> Self

Create an instance of a Reader with the specified parameters.

Trait Implementations

impl<IoImplementation: Debug, Inner: Debug, EofCondition: Debug, Buffer: Debug> Debug for Reader<IoImplementation, Inner, EofCondition, Buffer>

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

Formats the value using the given formatter.

impl<Inner, EofCondition> Reader for Reader<Tokio, Inner, EofCondition, BytesMut>where Inner: AsyncRead + Unpin, EofCondition: EofCondition<Result<usize, Error>>,

type Data<'data> = Bytes

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.