PairwiseStreamTransformer<T> constructor

PairwiseStreamTransformer<T>()

Constructs a StreamTransformer which buffers events into pairs as a List.

Implementation

PairwiseStreamTransformer()
    : super(WindowStrategy.firstEventOnly, (_) => NeverStream<void>(),
          onWindowEnd: (queue) => queue,
          startBufferEvery: 1,
          closeWindowWhen: (queue) => queue.length == 2,
          dispatchOnClose: false);