Trait AggregationWindowStreamExt 

pub trait AggregationWindowStreamExt<Key: Eq + Hash + Clone + Unpin, Input: TimeSeriesData<Key> + Unpin, AggInit: Clone + Unpin, AggValue, AggregatorImpl: Aggregator<AggInit, Input, AggValue>>: Stream<Item = Input> {
    // Provided method
    fn window_aggregate(
        self,
        window_duration: Duration,
        lateness: Duration,
        agg_init: AggInit,
        agg_fn: AggregatorImpl,
    ) -> WindowedAggregationStreamAdaptor<Key, Input, AggInit, AggValue, AggregatorImpl, Self>
       where Self: Sized { ... }
}

Provided Methods

fn window_aggregate( self, window_duration: Duration, lateness: Duration, agg_init: AggInit, agg_fn: AggregatorImpl, ) -> WindowedAggregationStreamAdaptor<Key, Input, AggInit, AggValue, AggregatorImpl, Self>

where Self: Sized,

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl<Key: Eq + Hash + Clone + Unpin, Input: TimeSeriesData<Key> + Unpin, AggInit: Clone + Unpin, AggValue, AggregatorImpl: Aggregator<AggInit, Input, AggValue>, I: Stream<Item = Input>> AggregationWindowStreamExt<Key, Input, AggInit, AggValue, AggregatorImpl> for I