to_sliding_window

stream_window

Function to_sliding_window 

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

Sliding window, waits till window of specified size is filled, emits, and slides down by one element.