Module streaming_split_segment 

Stop semantics (ADR-0025)

This segment implements OutcomePipeline and propagates PipelineOutcome::Stopped(ex) with the exchange state intact (including mutations made inside the segment body before Stop fired). See ADR-0025 §3 (stopped-exchange-state-preservation invariant).

Structs

StreamingSplitSegment

Outcome-aware StreamingSplit segment. Consumes a stream of fragment Exchanges via expression(exchange), runs body on each sequentially. On Stop: return Stopped(fragment_ex) immediately; the stream local is dropped when this future returns, closing the underlying stream resource. Aggregation is SKIPPED when Stop fires (spec §5.3).