exhaustAll method

Observable<T> exhaustAll({
  1. int concurrent = 1,
})

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

Implementation

Observable<T> exhaustAll({int concurrent = 1}) =>
    exhaustMap<T>(identityFunction, concurrent: concurrent);