Enum Compressor 

pub enum Compressor<W: AsyncWrite> {
    Noop(CountingWriter<W>),
    Zlib(ZlibEncoder<W>),
    Zstd(ZstdEncoder<CountingWriter<W>>),
}

Generic compressor.

Exposes a semi-type-erased compression stream, by allowing the compression to be configured via CompressionScheme, and generically wrapping over a given writer.

Variants

Noop(CountingWriter<W>)

No-op compressor.

Zlib(ZlibEncoder<W>)

Zlib compressor.

Zstd(ZstdEncoder<CountingWriter<W>>)

Zstd compressor.

Implementations

impl<W: AsyncWrite> Compressor<W>

pub fn from_scheme(scheme: CompressionScheme, writer: W) -> Self

Creates a new compressor from a given compression scheme and writer.

pub fn into_inner(self) -> W

Consumes the compressor, returning the inner writer.

pub fn content_encoding(&self) -> Option<HeaderValue>

Returns the content encoding for this compressor.

Trait Implementations

impl<W: AsyncWrite> AsyncWrite for Compressor<W>

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

Attempt to write bytes from buf into the object.

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

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

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<W: AsyncWrite> WriteStatistics for Compressor<W>

fn total_written(&self) -> u64

Returns the total number of bytes written.

impl<'pin, W: AsyncWrite> Unpin for Compressor<W>

where PinnedFieldsOf<__Compressor<'pin, W>>: Unpin,