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.