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 window(T event))
    : super(WindowStrategy.firstEventOnly, window,
          onWindowEnd: (List<T> queue) => queue, ignoreEmptyWindows: false) {
  if (window == null) throw ArgumentError.notNull('window');
}