WindowExtensions<T> extension
Extends the Stream class with the ability to window
- on
-
- Stream<
T>
- Stream<
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 aStream
and clears it, and starts a new buffer eachstartBufferEvery
values. IfstartBufferEvery
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 withduration
.