flatMapTo<R> method

Observable<R> flatMapTo<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> flatMapTo<R>(Observable<R> observable,
        {int concurrent = maxInteger}) =>
    mergeMapTo<R>(observable, concurrent: concurrent);