hunk.code_window: module.exports = function (suite) {
     var oldMergeAllWithImmediateScheduler = RxOld.Observable.range(0, 25, RxOld.Scheduler.immediate)
       .map(RxOld.Observable.range(0, 25), RxOld.Scheduler.immediate)
       .mergeAll();
  
hunk.labels: keep replace replace keep
hunk.after_edit:   var oldMergeAllWithImmediateScheduler = RxOld.Observable.fromArray(
       source.map(function () { return RxOld.Observable.range(0, 25, RxOld.Scheduler.immediate); }),
       RxOld.Scheduler.immediate
     )
  
hunk.file_path: perf/micro/immediate-scheduler/operators/mergeall.js
hunk.type: replace
file: import {Observable} from '../Observable';
  import {MergeAllOperator} from './mergeAll-support';
  
  /**
   * Joins every Observable emitted by the source (an Observable of Observables), in a serial
   * fashion. Subscribing to each one only when the previous one has completed, and merging
   * all of their values into the returned observable.
   *
   * __Warning:__ If the source Observable emits Observables quickly and endlessly, and the
   * Observables it emits generally complete slower than the source emits, you can run into
   * memory issues as the incoming observables collect in an unbounded buffer.
   *
   * @returns {Observable} an observable of values merged from the incoming observables.
   */
  export function concatAll<T>(): Observable<T> {
    return this.lift(new MergeAllOperator(1));
  }
  