Module aggregator 

Structs

AggregateEmission

A bucket emission delivered outside the submitting call (timeout fire, force_complete_all): the aggregated exchange plus every stashed drainclaim it completes. The consumer of the late channel MUST hold claims until the emission’s continuation pipeline (or reply) completes — dropping them IS the release.

AggregationReceipt

Result of AggregatorService::submit_with_claim.

AggregatorService

Constants

CAMEL_AGGREGATED_COMPLETION_REASON

CAMEL_AGGREGATED_KEY

CAMEL_AGGREGATED_SIZE

CAMEL_AGGREGATOR_PENDING

Functions

has_timeout_condition

Type Aliases

SharedLanguageRegistry