Function stream_window::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>> + 'aExpand description
Sliding window, waits till window of specified size is filled, emits, and slides down by one element.