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);