hunk.code_window:     var source = Observable.of(1, 2, 3, 4).publish();
       source.subscribe(function (x) {
         expect(x).toBe(expected[i++]);
       }, null,
       function () {
  
hunk.labels: keep keep keep keep replace keep
hunk.after_edit:     },
       null,
  
hunk.file_path: spec/operators/publish-spec.js
hunk.type: replace
file: var RxOld = require('rx');
  var RxNew = require('../../../../index');
  
  module.exports = function (suite) {
    var oldMergeAllWithImmediateScheduler = RxOld.Observable.range(0, 25, RxOld.Scheduler.immediate)
      .map(RxOld.Observable.range(0, 25), RxOld.Scheduler.immediate)
      .mergeAll();
    var newMergeAllWithImmediateScheduler = RxNew.Observable.range(0, 25)
      .mapTo(RxNew.Observable.range(0, 25))
      .mergeAll();
  
    function _next(x) { }
    function _error(e) { }
    function _complete() { }
    return suite
      .add('old mergeAll with immediate scheduler', function () {
        oldMergeAllWithImmediateScheduler.subscribe(_next, _error, _complete);
      })
      .add('new mergeAll with immediate scheduler', function () {
        newMergeAllWithImmediateScheduler.subscribe(_next, _error, _complete);
      });
  };
  