windowTest method
- bool onTestHandler(
- T event
Creates an Observable where each item is a Stream containing the items from the source sequence, batched whenever test passes.
Example
new Observable.periodic(const Duration(milliseconds: 100), (int i) => i)
.windowTest((i) => i % 2 == 0)
.asyncMap((stream) => stream.toList())
.listen(print); // prints [0], [1, 2] [3, 4] [5, 6] ...
Implementation
Observable<Stream<T>> windowTest(bool onTestHandler(T event)) =>
transform(WindowTestStreamTransformer(onTestHandler));