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});