Struct async_streamdata::reader::stream::Reader

pub struct Reader<T>(pub T);

A futures_core::Stream reader.

Allows reading any futures_core::Stream that returns Result<T, E>s where T implements bytes::Buf.

Tuple Fields

0: T

Trait Implementations

impl<T: Debug> Debug for Reader<T>

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

Formats the value using the given formatter.

impl<Stream, Data, Error> Reader for Reader<Stream>where Data: Buf, Stream: Stream<Item = Result<Data, Error>> + Unpin,

type Data<'data> = Data

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.