ExhaustMapOperator<T> extension

on

Methods

exhaustMap<R>(Map1<T, Observable<R>> project, {int concurrent: 1}) Observable<R>
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.
exhaustMapTo<R>(Observable<R> observable, {int concurrent: 1}) Observable<R>
Emits and completes values from single higher-order Observable. Subscribes to at most concurrent sources, drops observables exceeding this threshold.