PairwiseExtension<T> extension

Extends the Stream class with the ability to emit the nth and n-1th events as a pair

on

Methods

pairwise() Stream<List<T>>
Emits the n-th and n-1th events as a pair. The first event won't be emitted until the second one arrives.