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.
count is the maximum size of the buffer emitted
Rx.range(1, 4) .windowCount(2) .asyncMap((stream) => stream.toList()) .listen(print); // prints [1, 2], [3, 4] done!
if startBufferEvery is 2, then a new buffer will be started on every other value from the source. A new buffer is started at the beginning of the source by default.
Rx.range(1, 5) .bufferCount(3, 2) .listen(print); // prints [1, 2, 3], [3, 4, 5],  done!
- hashCode → int
The hash code for this object.
- runtimeType → Type
A representation of the runtime type of the object.
Stream< T>stream ) → Stream< Stream< T>>
Transforms the provided
RS, RT>( ) → StreamTransformer< RS, RT>
StreamTransformer<RS, RT>view of this stream transformer.inherited
Invocation invocation ) → dynamic
Invoked when a non-existent method or property is accessed.
) → String
Returns a string representation of this object.
dynamic other ) → bool
The equality operator.