exhaustMapTo<R> method

Observable<R> exhaustMapTo<R>(
  1. Observable<R> observable, {
  2. int concurrent = 1,
})

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

Implementation

Observable<R> exhaustMapTo<R>(Observable<R> observable,
        {int concurrent = 1}) =>
    exhaustMap<R>(constantFunction1(observable), concurrent: concurrent);