FlattenObservable<T> extension

on

Methods

flatten({int concurrent: maxInteger}) Observable<T>
For each observable of this Observable, subscribe to at most concurrent observables and emit all values.