GroupByExtension<T> extension

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

  • Stream<T>


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. [...]