GroupByExtension<T> extension

Extends the Stream class with the ability to convert events into Streams of events that are united by a key.

on

• Stream<T>

Methods

groupBy<K>(K grouper(T value), {Stream<void> durationSelector(GroupedStream<T, K> grouped)?}) → Stream<GroupedStream<T, K>>

Available on Stream<T>, provided by the GroupByExtension extension

The GroupBy operator divides a Stream that emits items into a Stream that emits GroupedStream, each one of which emits some subset of the items from the original source Stream.