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