flatten method

Observable<T> flatten({ 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);