FlatMapOperator<T> extension

on

• Observable<T>

Methods

flatMap<R>(Map1<T, Observable<R>> project, {int concurrent = maxInteger}) → Observable<R>

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

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>

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

For each value of this Observable, merge all values from the single higher-order observable. Subscribe to at most concurrent sources.