WindowExtensions<T> extension

Extends the Stream class with the ability to window

on

Methods

window(Stream window) Stream<Stream<T>>
Creates a Stream where each item is a Stream containing the items from the source sequence. [...]
windowCount(int count, [int startBufferEvery = 0]) Stream<Stream<T>>
Buffers a number of values from the source Stream by count then emits the buffer as a Stream and clears it, and starts a new buffer each startBufferEvery values. If startBufferEvery is not provided, then new buffers are started immediately at the start of the source and when each buffer closes and is emitted. [...]
windowTest(bool onTestHandler(T event)) Stream<Stream<T>>
Creates a Stream where each item is a Stream containing the items from the source sequence, batched whenever test passes. [...]
windowTime(Duration duration) Stream<Stream<T>>
Creates a Stream where each item is a Stream containing the items from the source sequence, sampled on a time frame with duration. [...]