Struct iroh_io::stats::TrackingStreamWriter

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

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

Implementations

impl<W> TrackingStreamWriter<W>

pub fn new(inner: W) -> Self

Create a new TrackingStreamWriter.

pub fn stats(&self) -> StreamWriterStats

Get the statistics about the write operations.

Trait Implementations

impl<W: AsyncStreamWriter> AsyncStreamWriter for TrackingStreamWriter<W>

type WriteFuture<'a> = AggregateStats<'a, <W as AsyncStreamWriter>::WriteFuture<'a>> where Self: 'a

Future returned by write

fn write<'a>(&'a mut self, data: &'a [u8]) -> Self::WriteFuture<'a>

Write the entire slice.

type WriteBytesFuture<'a> = AggregateStats<'a, <W as AsyncStreamWriter>::WriteBytesFuture<'a>> where Self: 'a

Future returned by write

fn write_bytes(&mut self, data: Bytes) -> Self::WriteBytesFuture<'_>

Write the entire bytes.

type SyncFuture<'a> = AggregateStats<'a, <W as AsyncStreamWriter>::SyncFuture<'a>> where Self: 'a

Future returned by sync

fn sync(&mut self) -> Self::SyncFuture<'_>

Sync any buffers to the underlying storage.

impl<W: Clone> Clone for TrackingStreamWriter<W>

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<W: Debug> Debug for TrackingStreamWriter<W>

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

Formats the value using the given formatter.