Module stream

Streaming system for PJS protocol

Provides frame-based streaming with priority-aware processing and compression integration.

Re-exports

pub use compression_integration::CompressedFrame;

pub use compression_integration::StreamingCompressor;

pub use compression_integration::StreamingDecompressor;

pub use compression_integration::CompressionStats;

pub use compression_integration::DecompressionStats;

pub use compression_integration::DecompressionMetadata;

pub use priority::PriorityStreamer;

Modules

compression_integration

Integration of schema-based compression with PJS streaming

priority

Priority-based JSON streaming implementation

Structs

StreamConfig

Stream processor configuration

StreamFrame

Stream frame with priority and metadata

StreamProcessor

Stream processor for handling PJS frames

StreamStats

Stream processing statistics

Enums

ProcessResult

Stream processing result