Struct StreamingCodec 

pub struct StreamingCodec { /* private fields */ }

Streaming codec for SSE compression

Maintains state across chunks for optimal compression and accumulates content for final aggregation.

Implementations

impl StreamingCodec

pub fn new() -> Self

Create a new streaming codec with default mode (Abbreviation)

pub fn with_mode(mode: StreamingMode) -> Self

Create codec with specific mode

pub fn token_native(encoding: Encoding) -> Self

Create codec with TokenNative mode and specific encoding

pub fn hybrid(encoding: Encoding) -> Self

Create codec with Hybrid mode (abbreviation + final TokenNative)

pub fn passthrough() -> Self

Create codec with compression disabled (passthrough)

pub fn mode(&self) -> StreamingMode

Get current streaming mode

pub fn parse_sse_line(&self, line: &str) -> Option<SseEvent>

Parse an SSE line into an event

pub fn process_chunk(&mut self, chunk: &[u8]) -> Result<Vec<Bytes>>

Process a raw SSE chunk (may contain multiple events)

pub fn accumulated_content(&self) -> &str

Get accumulated content from all chunks

pub fn finalize_token_native(&self) -> Result<CompressionResult>

Finalize streaming with TokenNative compression

For Hybrid mode, this compresses the full accumulated content using TokenNative for maximum compression.

Returns the compression result with statistics.

pub fn finalize_raw(&self) -> Vec<u8>

Finalize with raw bytes (no base64 overhead)

For binary-safe channels, returns raw VarInt-encoded token IDs.

pub fn finalize_m2m(&self, response_json: &str) -> Result<String>

Finalize streaming with M2M frame encoding

Wraps the accumulated content in an M2M response frame with:

• Response headers (model, token counts if available)
• Brotli compression for large content
• CRC32 integrity check

This is useful when you want to store or transmit the final accumulated response with full M2M wire format benefits.

Arguments

• response_json - Complete response JSON to wrap (should include the accumulated content)

Returns

M2M-encoded response as a string (base64 format for text transport)

pub fn finalize_m2m_binary(&self, response_json: &str) -> Result<Vec<u8>>

Finalize streaming with M2M frame encoding (binary)

Same as finalize_m2m but returns raw bytes instead of base64. Use this for binary-safe transport channels.

pub fn stats(&self) -> StreamingStats

Get compression statistics

pub fn reset(&mut self)

Reset the codec state

Trait Implementations

impl Debug for StreamingCodec

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for StreamingCodec

fn default() -> Self

Returns the “default value” for a type.