BufferExtensions<T> extension
Extends the Stream class with the ability to buffer events in various ways
- on
-
- Stream<
T>
- Stream<
Methods
-
buffer(
Stream window) → Stream< List< T> > - Creates a Stream where each item is a List containing the items from the source sequence.
-
bufferCount(
int count, [int startBufferEvery = 0]) → Stream< List< T> > -
Buffers a number of values from the source Stream by
count
then emits the buffer 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. -
bufferTest(
bool onTestHandler(T event)) → Stream< List< T> > - Creates a Stream where each item is a List containing the items from the source sequence, batched whenever test passes.
-
bufferTime(
Duration duration) → Stream< List< T> > -
Creates a Stream where each item is a List containing the items
from the source sequence, sampled on a time frame with
duration
.