exhaustMap<S> method

Stream<S> exhaustMap<S>(
  1. Stream<S> mapper(
    1. T value
    )
)

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.

Useful when you have a noisy source Stream and only want to respond once the previous async operation is finished.

Example

RangeStream(0, 2).interval(Duration(milliseconds: 50))
  .exhaustMap((i) =>
    TimerStream(i, Duration(milliseconds: 75)))
  .listen(print); // prints 0, 2

Implementation

Stream<S> exhaustMap<S>(Stream<S> Function(T value) mapper) =>
    ExhaustMapStreamTransformer<T, S>(mapper).bind(this);