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.


Observable<R> mergeMap<R>(Map1<T, Observable<R>> project,
    {int concurrent = maxInteger}) {
  RangeError.checkValidRange(1, null, concurrent, 'concurrent');
  return MergeObservable<T, R>(this, project, concurrent);