Struct TrackingStreamReader 

pub struct TrackingStreamReader<W> { /* private fields */ }

A stream writer that tracks the time spent in write operations.

Implementations

impl<W> TrackingStreamReader<W>

pub fn new(inner: W) -> Self

Create a new TrackingStreamWriter.

pub fn stats(&self) -> StreamReaderStats

Get the statistics about the write operations.

Trait Implementations

impl<W: AsyncStreamReader> AsyncStreamReader for TrackingStreamReader<W>

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>>

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]>>

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

impl<W: Clone> Clone for TrackingStreamReader<W>

fn clone(&self) -> TrackingStreamReader<W>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<W: Debug> Debug for TrackingStreamReader<W>

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

Formats the value using the given formatter.