pub type StreamingSplitExpression = Arc<dyn Fn(Exchange) -> Pin<Box<dyn Stream<Item = Result<Exchange, CamelError>> + Send>> + Send + Sync>;Expand description
A function that lazily produces a stream of exchange fragments.
Used by [StreamingSplitterService] for v1 sequential streaming split
(e.g., ZIP entry extraction, CSV/JSON streaming in future work).
Each call returns a Stream that yields fragments one at a time.
Aliased Typeยง
pub struct StreamingSplitExpression { /* private fields */ }