pub fn window_by_count(source: Stream, count: usize) -> StreamExpand description
Returns a stream that batches packets into windows of count packets each.
Each window is emitted as a data packet of stream_window_data_kind
whose payload lists the windowed packets; a trailing partial window is kept.