pairwise method

Observable<List<T>> pairwise ()

Triggers on the second and subsequent triggerings of the input observable. The Nth triggering of the input observable passes the arguments from the N-1th and Nth triggering as a pair.

Example

Observable.range(1, 4)
  .pairwise()
  .listen(print); // prints [1, 2], [2, 3]

Implementation

Observable<List<T>> pairwise() =>
    transform(BufferStreamTransformer<T>(onCount<T, List<T>>(2, 1),
        exhaustBufferOnDone: false));