ExhaustMapExtension<T> extension

Extends the Stream class with the ability to transform the Stream into a new Stream. The new Stream emits items and ignores events from the source Stream until the new Stream completes.

on

Methods

exhaustMap<S>(Stream<S> mapper(T value)) Stream<S>
Converts items from the source stream into a Stream using a given mapper. It ignores all items from the source stream until the new stream completes. [...]