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

• Stream<T>

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.