bufferTest method

Stream<List<T>> bufferTest (
  1. bool onTestHandler(
    1. T event
    )
)

Creates a Stream where each item is a List containing the items from the source sequence, batched whenever test passes.

Example

Stream.periodic(Duration(milliseconds: 100), (int i) => i)
  .bufferTest((i) => i % 2 == 0)
  .listen(print); // prints [0], [1, 2] [3, 4] [5, 6] ...

Implementation

Stream<List<T>> bufferTest(bool Function(T event) onTestHandler) =>
    transform(BufferTestStreamTransformer<T>(onTestHandler));