mergeAll method

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

For each observable of this Observable, subscribe to at most concurrent observables and emit all values.

Implementation

Observable<T> mergeAll({int concurrent = maxInteger}) =>
    mergeMap<T>(identityFunction, concurrent: concurrent);