mergeMap<R> method

Observable<R> mergeMap<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> mergeMap<R>(Map1<T, Observable<R>> project,
        {int concurrent = maxInteger}) =>
    MergeObservable<T, R>(this, project, concurrent);