hunk.code_window:     expectSubscriptions(e1.subscriptions).toBe(e1subs);
     });
     it('should handle a constant predicate on observable with many values', () => {
       const e1 = hot('-x-^-a-b-c-d-e-f-g-|');
       const e1subs =    '^               !';
       const expected =  '----------------(w|)';
       const predicate = () => {
         return 42;
       };
       expectObservable((<any>e1).min(predicate)).toBe(expected, { w: 42 });
       expectSubscriptions(e1.subscriptions).toBe(e1subs);
     });
     it('should handle a predicate on observable with many values', () => {
       const e1 = hot('-a-^-b--c--d-|', { a: 42, b: -1, c: 0, d: 666 });
       const e1subs =    '^         !';
       const expected =  '----------(w|)';
  
hunk.labels: keep keep keep replace replace replace replace replace replace replace replace replace replace replace replace replace replace keep keep keep
hunk.after_edit:   it('should handle a reverse predicate on observable with many values', () => {
  
hunk.file_path: spec/operators/min-spec.ts
hunk.type: replace
file: var RxOld = require('rx');
  var RxNew = require('../../../../index');
  
  var source = Array.apply(null, { length: 25 });
  
  module.exports = function (suite) {
    var oldMergeAllWithImmediateScheduler = RxOld.Observable.from(
      source.map(function () { return RxOld.Observable.range(0, 25, RxOld.Scheduler.immediate); }),
      null,
      this,
      RxOld.Scheduler.immediate
    )
      .switchFirst();
    var newMergeAllWithImmediateScheduler = RxNew.Observable.from(
      source.map(function () { return RxNew.Observable.range(0, 25); })
    )
      .exhaust();
  
    function _next(x) { }
    function _error(e) { }
    function _complete() { }
    return suite
      .add('old exhaust with immediate scheduler', function () {
        oldMergeAllWithImmediateScheduler.subscribe(_next, _error, _complete);
      })
      .add('new exhaust with immediate scheduler', function () {
        newMergeAllWithImmediateScheduler.subscribe(_next, _error, _complete);
      });
  };
  