Struct DecompressingStream 

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

A streaming decompressor that decompresses data on-the-fly

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

Example

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

// First compress some data
let original = b"Hello, streaming decompression!".repeat(100);
let cursor = std::io::Cursor::new(original.clone());
let mut compressor = CompressingStream::new(cursor, CompressionAlgorithm::Zstd, 5)?;

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

// Now decompress it
let cursor = std::io::Cursor::new(compressed);
let mut decompressor = DecompressingStream::new(cursor, CompressionAlgorithm::Zstd)?;

let mut decompressed = Vec::new();
decompressor.read_to_end(&mut decompressed).await?;

assert_eq!(original, decompressed);

Implementations

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

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

Create a new decompressing stream

Arguments

• reader - The source to read compressed data from
• algorithm - The compression algorithm that was used

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

Create a new decompressing stream with a custom buffer size

Arguments

• reader - The source to read compressed data from
• algorithm - The compression algorithm that was used
• buffer_size - Size of the internal buffer in bytes

pub fn stats(&self) -> &StreamingStats

Get statistics about the decompression operation

Trait Implementations

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

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

Attempts to read from the AsyncRead into buf.