Struct forest_filecoin::utils::io::writer_checksum::AsyncWriterWithChecksum

pub struct AsyncWriterWithChecksum<D, W> {
    inner: BufWriter<W>,
    hasher: Option<D>,
}

Wrapper AsyncWriter implementation that calculates the optional checksum on the fly. Both Writer and Digest parameters are generic so one can use freely the relevant structures, e.g. BufWriter and Sha256.

Fields

inner: BufWriter<W>

hasher: Option<D>

Implementations

impl<D: Digest, W> AsyncWriterWithChecksum<D, W>

pub fn new(writer: BufWriter<W>, checksum_enabled: bool) -> Self

Trait Implementations

impl<D: Digest, W: AsyncWriteExt> AsyncWrite for AsyncWriterWithChecksum<D, W>

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

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<D: Digest, W: AsyncWriteExt> Checksum<D> for AsyncWriterWithChecksum<D, W>

fn finalize(&mut self) -> Result<Option<Output<D>>>

Return the checksum and resets the internal hasher.

impl<'__pin, D, W> Unpin for AsyncWriterWithChecksum<D, W>

where __Origin<'__pin, D, W>: Unpin,