GroupByExtension<T> extension

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



groupBy<S>(S grouper(T value)) Stream<GroupByStream<T, S>>
The GroupBy operator divides a Stream that emits items into a Stream that emits GroupByStream, each one of which emits some subset of the items from the original source Stream. [...]