bufferTest method

Observable<List<T>> bufferTest (bool onTestHandler(T event))

Creates an Observable where each item is a List containing the items from the source sequence, batched whenever onTestHandler passes.

Example

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

Implementation

Observable<List<T>> bufferTest(bool onTestHandler(T event)) => transform(
    new BufferStreamTransformer<T>(onTest<T, List<T>>(onTestHandler)));