Struct SplitterService 

pub struct SplitterService { /* private fields */ }

Tower Service implementing the Splitter EIP.

Splits an incoming exchange into fragments via a configurable expression, processes each fragment through a sub-pipeline, and aggregates the results.

DoS bound (R3-M4): the eager splitter materializes the whole fragment Vec before processing. SplitterConfig::max_fragments (default 100_000) rejects a split that would explode memory. For unbounded or lazy byte-stream input, prefer StreamingSplitterService, which processes fragments as they arrive and never materializes the full set.

Note: In parallel mode, stop_on_exception only affects the aggregation phase. All spawned fragments run to completion because join_all cannot cancel in-flight futures. Sequential mode stops processing immediately.

Implementations

impl SplitterService

pub fn new( config: SplitterConfig, sub_pipeline: BoxProcessor, ) -> Result<Self, CamelError>

Create a new SplitterService from a SplitterConfig and a sub-pipeline.

pub fn cancel(&self)

Cancel all in-flight parallel tasks and prevent new ones from starting.

pub fn is_cancelled(&self) -> bool

Check whether the splitter has been cancelled.

Trait Implementations

impl Clone for SplitterService

fn clone(&self) -> SplitterService

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Service<Exchange> for SplitterService

type Response = Exchange

Responses given by the service.

type Error = CamelError

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<Exchange, CamelError>> + Send>>

The future response value.

fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, exchange: Exchange) -> Self::Future

Process the request and return the response asynchronously.