GroupByStreamTransformer<T, K> constructor

GroupByStreamTransformer<T, K>(
  1. K grouper(
    1. T event
    ),
  2. {Stream<void> durationSelector(
    1. GroupedStream<T, K> grouped
    )?}
)

Constructs a StreamTransformer which groups events from the source Stream and emits them as GroupedStream.

Implementation

GroupByStreamTransformer(this.grouper, {this.durationSelector});