hunk.code_window:   it('should emit an error when the selector throws', function (done) {
       function callback(cb) {
         cb(42);
       }
       var boundCallback = Observable.bindCallback(callback, null, function (err) { throw new Error('Yikes!'); });
       boundCallback()
         .subscribe(function () {
  
hunk.labels: keep keep keep keep replace keep keep keep
hunk.after_edit:     var boundCallback = Observable.bindCallback(callback, function (err) { throw new Error('Yikes!'); });
  
hunk.file_path: spec/observables/bindCallback-spec.js
hunk.type: replace
file: var RxOld = require('rx');
  var RxNew = require('../../../../index');
  
  module.exports = function _throw(suite) {
    var oldThrowWithCurrentThreadScheduler = RxOld.Observable.throw(new Error('error'), RxOld.Scheduler.currentThread);
    var newThrowWithCurrentThreadScheduler = RxNew.Observable.throw(new Error('error'), RxNew.Scheduler.immediate);
  
    function _next(x) { }
    function _error(e) { }
    function _complete() { }
    // add tests
    return suite
      .add('old throw with current thread scheduler', function () {
        oldThrowWithCurrentThreadScheduler.subscribe(_next, _error, _complete);
      })
      .add('new throw with current thread scheduler', function () {
        newThrowWithCurrentThreadScheduler.subscribe(_next, _error, _complete);
      });
  };