Skip to main content

compress_stream

Function compress_stream 

Source
pub fn compress_stream<R: Read>(
    r: R,
    chunk_size: usize,
    compressor: Box<dyn Compressor>,
) -> impl Iterator<Item = Result<Vec<u8>, CompressionError>>
Expand description

Summary: Compress data read from R in chunk_size blocks, yielding compressed chunks.

  • Respects MAX_CHUNK_SIZE sanity.
  • Calls compressor.finish() after EOF to flush pending state.