Struct AsyncStreamingCompressor 

pub struct AsyncStreamingCompressor { /* private fields */ }

Async streaming compressor wrapper.

Wraps a StreamingCompressor for use with async streams.

Implementations

impl AsyncStreamingCompressor

pub fn new(config: StreamingConfig) -> Result<Self>

Create a new async streaming compressor.

pub fn encoding(&self) -> Option<&'static str>

Get the Content-Encoding header value.

pub async fn process(&mut self, chunk: Bytes) -> Result<Bytes>

Process a chunk and return compressed data.

pub async fn flush(&mut self) -> Result<Bytes>

Flush any pending compressed data.

pub fn finish(self) -> Result<Bytes>

Finish compression.

pub fn stats(&self) -> CompressionStats

Get compression statistics.