ExhaustMapOperator<T> extension

on

• Observable<T>

Methods

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

Available on Observable<T>, provided by the ExhaustMapOperator extension

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>

Available on Observable<T>, provided by the ExhaustMapOperator extension

Emits and completes values from single higher-order Observable. Subscribes to at most concurrent sources, drops observables exceeding this threshold.