Crate haagenti_stream 

Haagenti Stream

Advanced streaming compression utilities.

Provides buffered streams, adapters, and I/O integration for efficient streaming compression operations.

Features

• Buffered Streams: Memory-efficient buffering
• I/O Integration: Read/Write trait implementations
• Backpressure: Flow control for slow consumers

Example

use haagenti_stream::CompressWriter;
use haagenti_lz4::Lz4Compressor;
use std::io::Write;

let file = File::create("output.lz4")?;
let mut writer = CompressWriter::new(file, Lz4Compressor::new());

writer.write_all(b"Hello, compression!")?;
writer.finish()?;

Structs

CompressWriter

A writer that compresses data before writing to the inner writer.

DecompressReader

A reader that decompresses data from the inner reader.

ReadAdapter

A generic read adapter for transforming data.

StreamBuffer

A reusable buffer for streaming operations.

WriteAdapter

A generic write adapter for transforming data.

Constants

DEFAULT_BUFFER_SIZE

Default buffer size for streaming operations (64 KB).

MAX_BUFFER_SIZE

Maximum buffer size allowed (1 MB).

MIN_BUFFER_SIZE

Minimum buffer size allowed.

Functions

clamp_buffer_size

Clamp buffer size to valid range.