pub fn window<T: Clone + Send + 'static>(
size: usize,
s: impl Stream<Item = T> + Send + 'static,
) -> impl Stream<Item = Vec<T>>Expand description
Split source into windows of specified size. Each window is a vector of items (simpler than sub-streams).