flatMap<R> method

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

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.

Implementation

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