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>
- Stream<
Methods
-
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.