mergeMapTo<R> method

Observable<R> mergeMapTo<R>(
  1. Observable<R> observable, {
  2. int concurrent = maxInteger,
})

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

Implementation

Observable<R> mergeMapTo<R>(Observable<R> observable,
        {int concurrent = maxInteger}) =>
    mergeMap<R>(constantFunction1(observable), concurrent: concurrent);