pub type AggregationFn = Arc<dyn Fn(Exchange, Exchange) -> Exchange + Send + Sync>;
Aggregation function — left-fold binary: (accumulated, next) -> merged.
pub struct AggregationFn { /* private fields */ }