WindowExtensions<T> extension

Extends the Stream class with the ability to window

on

Methods

window(Stream window) → Stream<Stream<T>>: Available on Stream<T>, provided by the WindowExtensions extension
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>>: Available on Stream<T>, provided by the WindowExtensions extension
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>>: Available on Stream<T>, provided by the WindowExtensions extension
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>>: Available on Stream<T>, provided by the WindowExtensions extension
Creates a Stream where each item is a Stream containing the items from the source sequence, sampled on a time frame with duration.