Type Alias BoxProcessor 

pub type BoxProcessor = BoxCloneService<Exchange, Exchange, CamelError>;

A type-erased, cloneable processor. This is the main runtime representation of a processor pipeline — a composed chain of Tower Services erased to a single boxed type.

Aliased Type

pub struct BoxProcessor(/* private fields */);

Trait Implementations

impl BoxProcessorExt for BoxProcessor

fn from_fn<F, Fut>(f: F) -> BoxProcessor

where F: Fn(Exchange) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<Exchange, CamelError>> + Send + 'static,

Create a BoxProcessor from an async closure.

impl RetryableStep for BoxProcessor

BoxProcessor adapter: preserves readiness-error routing by calling ServiceExt::ready().await before Service::call(). Readiness failures (e.g. channel closed, circuit breaker open) become PipelineOutcome::Failed, NOT panic or silent skip.

fn invoke<'a>( &'a mut self, exchange: Exchange, ) -> Pin<Box<dyn Future<Output = PipelineOutcome> + Send + 'a>>