hunk.code_window: module.exports = function (suite) {
     var oldConcatWithCurrentThreadScheduler = RxOld.Observable.range(0, 25, RxOld.Scheduler.currentThread)
       .concat(RxOld.Observable.range(0, 25, RxOld.Scheduler.currentThread));
     var newConcatWithCurrentThreadScheduler = RxNew.Observable.range(0, 25)
       .concat(RxNew.Observable.range(0, 25));
     function _next(x) { }
     function _error(e) { }
     function _complete() { }
  
hunk.labels: keep keep keep replace replace keep keep keep keep
hunk.after_edit:   var newConcatWithCurrentThreadScheduler = RxNew.Observable.range(0, 25, RxNew.Scheduler.queue)
       .concat(RxNew.Observable.range(0, 25, RxNew.Scheduler.queue));
  
hunk.file_path: perf/micro/current-thread-scheduler/operators/concat.js
hunk.type: replace
file: /* globals describe, it, expect */
  var Rx = require('../../dist/cjs/Rx');
  var Observable = Rx.Observable;
  
  describe('Observable.throw', function () {
    it('should emit one value', function (done) {
      var calls = 0;
      Observable.throw('bad').subscribe(function () {
        throw 'should not be called';
      }, function (err) {
        expect(++calls).toBe(1);
        expect(err).toBe('bad');
        done();
      });
    });
  });