FlatMapOperator<T> extension

on

Methods

flatMap<R>(Map1<T, Observable<R>> project, {int concurrent = maxInteger}) Observable<R>
For each value of this Observable, transform that value to a higher-order observable with the provided project function and merge its emitted values. Subscribe to at most concurrent sources.
flatMapTo<R>(Observable<R> observable, {int concurrent = maxInteger}) Observable<R>
For each value of this Observable, merge all values from the single higher-order observable. Subscribe to at most concurrent sources.