Struct Aggregator 

pub struct Aggregator { /* private fields */ }

Implementations

impl Aggregator

pub fn new<C, M>( correlation: C, combine: M, config: AggregatorConfig, downstream: Arc<dyn Processor>, ) -> Arc<Self>

where C: Fn(&Exchange) -> Option<String> + Send + Sync + 'static, M: Fn(Option<Exchange>, Exchange) -> Exchange + Send + Sync + 'static,

pub fn from_arcs( correlation: Arc<CorrelationFn>, combine: Arc<CombineFn>, config: AggregatorConfig, downstream: Arc<dyn Processor>, ) -> Arc<Self>

Type-erased constructor used by code paths that already hold Arc<CorrelationFn> / Arc<CombineFn> (e.g. the DSL’s node fold).

Trait Implementations

impl Processor for Aggregator

fn process<'life0, 'life1, 'async_trait>( &'life0 self, exchange: &'life1 mut Exchange, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,