Module splitter 

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. Non-array bodies produce an empty vec.

split_body_lines

Split the exchange body by newlines. Returns one fragment per line. Non-text bodies produce an empty vec.

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.