Struct tokio_util::io::InspectWriter

pub struct InspectWriter<W, F> { /* private fields */ }

An adapter that lets you inspect the data that’s being written.

This is useful for things like hashing data as it’s written out.

Implementations

impl<W, F> InspectWriter<W, F>

pub fn new(writer: W, f: F) -> InspectWriter<W, F>where W: AsyncWrite, F: FnMut(&[u8]),

Create a new InspectWriter, wrapping write and calling f for the data successfully written by each write call.

The closure f will never be called with an empty slice. A vectored write can result in multiple calls to f - at most one call to f per buffer supplied to poll_write_vectored.

pub fn into_inner(self) -> W

Consumes the InspectWriter, returning the wrapped writer

Trait Implementations

impl<W: AsyncWrite, F: FnMut(&[u8])> AsyncWrite for InspectWriter<W, F>

fn poll_write( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &[u8] ) -> Poll<Result<usize>>

Attempt to write bytes from buf into the object.

fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>>

Attempts to flush the object, ensuring that any buffered data reach their destination.

fn poll_shutdown(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>>

Initiates or attempts to shut down this writer, returning success when the I/O connection has completely shut down.

fn poll_write_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>] ) -> Poll<Result<usize>>

Like poll_write, except that it writes from a slice of buffers.

fn is_write_vectored(&self) -> bool

Determines if this writer has an efficient poll_write_vectored implementation.

impl<'__pin, W, F> Unpin for InspectWriter<W, F>where __Origin<'__pin, W, F>: Unpin,