pub trait AggregationProvider<Value, Timestamp> {
    // Required method
    fn aggregate(
        pairs: impl IntoIterator<Item = (Value, Timestamp)>
    ) -> Option<(Value, Timestamp)>;
}
Expand description

Defined an aggregation behavior

Required Methods§

Object Safety§

This trait is not object safe.

Implementors§

source§

impl<Value, Timestamp> AggregationProvider<Value, Timestamp> for MedianAggregation
where Value: Ord + Clone, Timestamp: Ord + Clone,