BufferTestStreamTransformer<T> constructor

BufferTestStreamTransformer<T>(
  1. bool test(
    1. T value
    )
)

Constructs a StreamTransformer which buffers events into a List and emits this List whenever the test Function yields true.

Implementation

BufferTestStreamTransformer(bool Function(T value) test)
    : super(WindowStrategy.onHandler, null,
          onWindowEnd: (queue) => queue,
          closeWindowWhen: (queue) => test(queue.last));