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);