WindowExtensions<T> extension

Extends the Stream class with the ability to window

on

• Stream<T>

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.