BufferStreamTransformer<T> constructor
BufferStreamTransformer<T> (
- Stream window(
- T event
Constructs a StreamTransformer which buffers events into a List and
emits this List whenever window
fires an event.
The List is cleared upon every window
event.
Implementation
BufferStreamTransformer(Stream Function(T event) window)
: super(WindowStrategy.firstEventOnly, window,
onWindowEnd: (queue) => queue, ignoreEmptyWindows: false);