flatten method

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

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

Implementation

Observable<T> flatten({int concurrent = maxInteger}) =>
    mergeAll(concurrent: concurrent);