Struct Aggregator 

pub struct Aggregator { /* private fields */ }

Implementations

impl Aggregator

pub fn new<H>(correlation_header: H, completion_size: usize) -> Aggregator

where H: Into<String>,

Create a new Aggregator.

• correlation_header – header key used to group messages (e.g. “corr” or “correlation_id”).
• completion_size – number of messages required before aggregation triggers.

pub fn clear_store(&self)

Clear all stored partial groups. Intended for test isolation; not usually needed in production.

Trait Implementations

impl Clone for Aggregator

fn clone(&self) -> Aggregator

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Aggregator

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Processor for Aggregator

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

where 'life0: 'async_trait, 'life1: 'async_trait, Aggregator: 'async_trait,