Struct SplitterConfig 

pub struct SplitterConfig {
    pub expression: SplitExpression,
    pub aggregation: AggregationStrategy,
    pub parallel: bool,
    pub parallel_limit: Option<usize>,
    pub stop_on_exception: bool,
}

Configuration for the Splitter EIP.

Fields

expression: SplitExpression

Expression that splits an exchange into fragments.

aggregation: AggregationStrategy

How to aggregate fragment results.

parallel: bool

Whether to process fragments in parallel.

parallel_limit: Option<usize>

Maximum number of parallel fragments (None = unlimited).

stop_on_exception: bool

Whether to stop processing on the first exception.

In parallel mode this only affects aggregation (the first error is propagated), not in-flight futures — join_all cannot cancel already-spawned work.

Implementations

impl SplitterConfig

pub fn new(expression: SplitExpression) -> Self

Create a new splitter config with the given split expression.

pub fn aggregation(self, strategy: AggregationStrategy) -> Self

Set the aggregation strategy for combining fragment results.

pub fn parallel(self, parallel: bool) -> Self

Enable or disable parallel fragment processing.

pub fn parallel_limit(self, limit: usize) -> Self

Set the maximum number of concurrent fragments in parallel mode.

pub fn stop_on_exception(self, stop: bool) -> Self

Control whether processing stops on the first fragment error.

In parallel mode this only affects aggregation — see the field-level doc comment for details.