Struct CompressingStream 

pub struct CompressingStream<R: AsyncRead + Unpin> { /* private fields */ }

A streaming compressor that compresses data on-the-fly

This struct wraps an AsyncRead source and compresses the data as it’s read, providing an efficient way to compress large files without loading them entirely into memory.

Example

use ipfrs_core::streaming_compression::{CompressingStream, CompressionAlgorithm};
use tokio::io::AsyncReadExt;
use bytes::Bytes;

let data = b"Hello, streaming compression!".repeat(100);
let cursor = std::io::Cursor::new(data.clone());

let mut stream = CompressingStream::new(cursor, CompressionAlgorithm::Zstd, 5)?;

let mut compressed = Vec::new();
stream.read_to_end(&mut compressed).await?;

let stats = stream.stats();
println!("Compressed {} bytes to {} bytes", stats.bytes_read, stats.bytes_written);

Implementations

impl<R: AsyncRead + Unpin> CompressingStream<R>

pub fn new( reader: R, algorithm: CompressionAlgorithm, level: u8, ) -> Result<Self>

Create a new compressing stream

Arguments

• reader - The source to read uncompressed data from
• algorithm - The compression algorithm to use
• level - Compression level (0-9)

Returns

A new CompressingStream instance

pub fn with_buffer_size( reader: R, algorithm: CompressionAlgorithm, level: u8, buffer_size: usize, ) -> Result<Self>

Create a new compressing stream with a custom buffer size

Arguments

• reader - The source to read uncompressed data from
• algorithm - The compression algorithm to use
• level - Compression level (0-9)
• buffer_size - Size of the internal buffer in bytes

pub fn stats(&self) -> &StreamingStats

Get statistics about the compression operation

Trait Implementations

impl<R: AsyncRead + Unpin> AsyncRead for CompressingStream<R>

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut ReadBuf<'_>, ) -> Poll<Result<()>>

Attempts to read from the AsyncRead into buf.