hunk.code_window: var RxOld = require('rx');
   var RxNew = require('../../../../index');
   module.exports = function (suite) {
  
hunk.labels: keep keep add keep
hunk.after_edit: var source = Array.apply(null, { length: 25 });
  
hunk.file_path: perf/micro/current-thread-scheduler/operators/mergeall.js
hunk.type: add
file: var RxOld = require('rx');
  var RxNew = require('../../../../index');
  
  module.exports = function (suite) {
    function add(acc, x) {
      return x + x;
    }
    var oldReduceWithImmediateScheduler = RxOld.Observable.range(0, 25, RxOld.Scheduler.immediate).reduce(add);
    var newReduceWithImmediateScheduler = RxNew.Observable.range(0, 25).reduce(add);
  
    function _next(x) { }
    function _error(e) { }
    function _complete() { }
    return suite
        .add('old reduce with immediate scheduler', function () {
          oldReduceWithImmediateScheduler.subscribe(_next, _error, _complete);
        })
        .add('new reduce with immediate scheduler', function () {
          newReduceWithImmediateScheduler.subscribe(_next, _error, _complete);
        });
  };