Struct CompressedWriter 

pub struct CompressedWriter {
    inner: Box<dyn AsyncWrite + Unpin + Send>,
    compression_type: CompressionType,
}

A compressed writer that wraps an underlying async writer with compression.

This writer supports multiple compression formats including GZIP, BZIP2, XZ, and ZSTD. It provides transparent compression for any async writer implementation.

Fields

inner: Box<dyn AsyncWrite + Unpin + Send>

compression_type: CompressionType

Implementations

impl CompressedWriter

pub fn new( writer: impl AsyncWrite + Unpin + Send + 'static, compression_type: CompressionType, ) -> Self

Creates a new compressed writer with the specified compression type.

Arguments

• writer - The underlying writer to wrap with compression
• compression_type - The type of compression to apply

pub fn compression_type(&self) -> CompressionType

Returns the compression type used by this writer.

pub async fn shutdown(self) -> Result<()>

Flush the writer and shutdown compression

Trait Implementations

impl AsyncWrite for CompressedWriter

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.