Struct TrackingReader

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

A reader that tracks the number of bytes read

Implementations

impl<R> TrackingReader<R>

pub fn new(inner: R) -> Self

Wrap a reader in a tracking reader

pub fn bytes_read(&self) -> u64

Get the number of bytes read

pub fn into_parts(self) -> (R, u64)

Get the inner reader

Trait Implementations

impl<R> AsyncStreamReader for TrackingReader<R>

where R: AsyncStreamReader,

async fn read_bytes(&mut self, len: usize) -> Result<Bytes>

Read at most len bytes. To read to the end, pass u64::MAX.

async fn read<const L: usize>(&mut self) -> Result<[u8; L]>

Read a fixed size buffer.

fn read_bytes_exact( &mut self, len: usize, ) -> impl Future<Output = Result<Bytes, Error>>

Variant of read_bytes that returns an error if less than len bytes are read.

fn read_exact<const L: usize>( &mut self, ) -> impl Future<Output = Result<[u8; L], Error>>

Variant of read that returns an error if less than L bytes are read.

impl<R: Debug> Debug for TrackingReader<R>

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

Formats the value using the given formatter.