hunk.code_window: var RxOld = require('rx');
   var RxNew = require('../../../../index');
   module.exports = function (suite) {
     var oldBufferCountWithCurrentThreadScheduler = RxOld.Observable.range(0, 25, RxOld.Scheduler.currentThread).bufferWithCount(5);
     var newBufferCountWithCurrentThreadScheduler = RxNew.Observable.range(0, 25).bufferCount(5);
     function _next(x) { }
     function _error(e) { }
  
hunk.labels: keep keep keep keep keep replace keep keep keep
hunk.after_edit:   var newBufferCountWithCurrentThreadScheduler = RxNew.Observable.range(0, 25, RxNew.Scheduler.queue).bufferCount(5);
  
hunk.file_path: perf/micro/current-thread-scheduler/operators/buffercount.js
hunk.type: replace
file: var RxOld = require('rx');
  var RxNew = require('../../../../index');
  var Event = require('events');
  
  module.exports = function fromEventPattern(suite) {
    var eventName = 'testEvent';
  
    var oldRxEventEmitter = new Event.EventEmitter();
    var newRxEventEmitter = new Event.EventEmitter();
  
    var oldFromEventPatternWithImmediateScheduler = RxOld.Observable.fromEventPattern(
      function add(h) {
        oldRxEventEmitter.addListener(eventName, h);
      },
      function remove(h) {
        oldRxEventEmitter.removeListener(eventName, h);
      }).take(1);
  
    var newFromEventPatternWithImmediateScheduler = RxNew.Observable.fromEventPattern(
      function add(h) {
        newRxEventEmitter.addListener(eventName, h);
      },
      function remove(h) {
        newRxEventEmitter.removeListener(eventName, h);
      }).take(1);
  
    function _next(x) { }
    function _error(e) { }
    function _complete() { }
  
    return suite
      .add('old fromEventPattern with immediate scheduler', function () {
        oldFromEventPatternWithImmediateScheduler.subscribe(_next, _error, _complete);
        oldRxEventEmitter.emit(eventName);
      })
      .add('new fromEventPattern with immediate scheduler', function () {
        newFromEventPatternWithImmediateScheduler.subscribe(_next, _error, _complete);
        newRxEventEmitter.emit(eventName);
      });
  };