Module stream_pipeline 

Phase-aware streaming pipeline for real-time data emission.

StreamPipeline implements the PhaseSink trait, allowing generated data to be streamed to files or HTTP endpoints as it is produced, rather than buffering everything in memory.

Structs

StreamPipeline

A streaming pipeline that writes generated data as JSONL envelopes.

StreamStats

Accumulated statistics for a streaming pipeline.

Enums

BackpressureStrategy

Strategy for handling back-pressure when the sink cannot keep up.

StreamError

Errors that can occur during streaming.

StreamTarget

Where the stream sends its data.

Traits

PhaseSink

Trait for sinks that receive generated items phase-by-phase.