FlattenObservable<T> extension

on

• Observable<Observable<T>>

Methods

flatten({int concurrent = maxInteger}) → Observable<T>

Available on Observable<Observable<T>>, provided by the FlattenObservable extension

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