to_tumbling_window

stream_window

Function to_tumbling_window 

Source 
pub fn to_tumbling_window<'a, T: Clone + 'a>(
    stream: impl Stream<Item = T> + Unpin + 'a,
    window_size: usize,
) -> impl Stream<Item = Vec<T>> + 'a
Expand description

Tumbling window, waits till window of specified size is filled, emits, and starts a new window.