GroupByStream<T, S> constructor

GroupByStream<T, S>(
  1. S key,
  2. Stream<T> stream
)

Constructs a Stream which only emits events that can be categorized under key.

Implementation

GroupByStream(this.key, Stream<T> stream) : super(stream);