exhaustMap<R> method

Observable<R> exhaustMap<R>(
  1. Map1<T, Observable<R>> project, {
  2. int concurrent = 1,
})

Emits and completes values from a higher-order Observable retrieved by projecting the values of the source to higher-order Observables. Subscribes to at most concurrent sources, drops observables exceeding this threshold.

Implementation

Observable<R> exhaustMap<R>(
  Map1<T, Observable<R>> project, {
  int concurrent = 1,
}) => ExhaustObservable<T, R>(this, project, concurrent);