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.



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.