GroupByExtension<T> extension

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



groupBy<K>(K grouper(T value), {Stream<void> durationSelector(GroupedStream<T, K> grouped)?}) Stream<GroupedStream<T, K>>
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.