ExhaustMapOperator<T> extension
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.
