hunk.code_window:     let len = marbles.length;
       let results: ({ frame: number, notification: Notification<any> })[] = [];
       let subIndex = marbles.indexOf('^');
       let frameOffset = subIndex === -1 ? 0 : (subIndex * -10);
       let getValue = typeof values !== 'object' ? (x) => x : (x) => values[x];
       let groupStart = -1;
       for (let i = 0; i < len; i++) {
  
hunk.labels: keep keep keep replace keep keep keep keep
hunk.after_edit:     let frameOffset = subIndex === -1 ? 0 : (subIndex * -this.frameTimeFactor);
  
hunk.file_path: src/schedulers/TestScheduler.ts
hunk.type: replace
file: var RxOld = require("rx");
  var RxNew = require("../../../../index");
  
  module.exports = function (suite) {
  
      var oldMergeMapWithImmediateScheduler = RxOld.Observable.range(0, 25, RxOld.Scheduler.immediate).flatMap(RxOld.Observable.range(0, 25, RxOld.Scheduler.immediate));
      var newMergeMapWithImmediateScheduler = RxNew.Observable.range(0, 25).mergeMapTo(RxNew.Observable.range(0, 25));
  
      return suite
          .add('old mergeMap (Observable) with immediate scheduler', function () {
              oldMergeMapWithImmediateScheduler.subscribe(_next, _error, _complete);
          })
          .add('new mergeMap (Observable) with immediate scheduler', function () {
              newMergeMapWithImmediateScheduler.subscribe(_next, _error, _complete);
          });
      function _next(x) { }
      function _error(e){ }
      function _complete(){ }
  };