Skip to main content

Module splitter

Module splitter 

Source

Structs§

SplitterConfig
Configuration for the Splitter EIP.
StreamSplitConfig
Configuration for splitting a streaming body into fragments.

Enums§

AggregationStrategy
Strategy for aggregating fragment results back into a single exchange.
StreamSplitFormat
The streaming format to use when splitting a stream body.

Functions§

fragment_exchange
Create a fragment exchange that inherits headers, properties, and OTel context from the parent, but with a new body.
split_body
Split the exchange body using a custom function that operates on the body.
split_body_json_array
Split a JSON array body into one fragment per element.
split_body_lines
Split the exchange body by newlines. Returns one fragment per line.
streaming_split_type_error
Typed error returned when a streaming split receives a body that is not Body::Stream. Shared by the compiled production expression, the test mirrors, and examples so the message cannot drift between copies.

Type Aliases§

SplitExpression
A function that splits a single exchange into multiple fragment exchanges.
StreamingSplitExpression
A function that lazily produces a stream of exchange fragments.