hunk.code_window:     const expected =  '----------(w|)';
       const predicate = function (x, y) {
         return x < y ? x : y;
       };
  
hunk.labels: keep keep keep replace keep keep
hunk.after_edit:       return x > y ? -1 : 1;
  
hunk.file_path: spec/operators/min-spec.ts
hunk.type: replace
file: var RxOld = require('rx');
  var RxNew = require('../../../../index');
  
  module.exports = function (suite) {
    function add(acc, x) {
      return x + x;
    }
    var oldReduceWithCurrentThreadScheduler = RxOld.Observable.range(0, 25, RxOld.Scheduler.currentThread).reduce(add);
    var newReduceWithCurrentThreadScheduler = RxNew.Observable.range(0, 25, RxNew.Scheduler.queue).reduce(add);
  
    function _next(x) { }
    function _error(e) { }
    function _complete() { }
    return suite
      .add('old reduce with current thread scheduler', function () {
        oldReduceWithCurrentThreadScheduler.subscribe(_next, _error, _complete);
      })
      .add('new reduce with current thread scheduler', function () {
        newReduceWithCurrentThreadScheduler.subscribe(_next, _error, _complete);
      });
  };