hunk.code_window:   it('should emit one value chosen by a selector', function (done) {
       function callback(datum, cb) {
         cb(null, datum);
       }
       var boundCallback = Observable.bindCallback(callback, null, function (err, datum) { return datum; });
       boundCallback(42)
         .subscribe(function (x) {
           expect(x).toBe(42);
  
hunk.labels: keep keep keep keep keep replace keep keep keep keep
hunk.after_edit:     var boundCallback = Observable.bindCallback(callback, function (err, datum) { return datum; });
  
hunk.file_path: spec/observables/bindCallback-spec.js
hunk.type: replace
file: var RxOld = require('rx');
  var RxNew = require('../../../../index');
  
  module.exports = function fromArray(suite) {
    var args = [];
    for (var i = 0; i < 25; i++) {
      args.push(i);
    }
  
    var oldFromArrayWithCurrentThreadScheduler = RxOld.Observable.fromArray(args, RxOld.Scheduler.currentThread);
    var newFromArrayWithCurrentThreadScheduler = RxNew.Observable.fromArray(args, RxNew.Scheduler.immediate);
  
    function _next(x) { }
    function _error(e) { }
    function _complete() { }
    // add tests
    return suite
      .add('old fromArray with current thread scheduler', function () {
        oldFromArrayWithCurrentThreadScheduler.subscribe(_next, _error, _complete);
      })
      .add('new fromArray with current thread scheduler', function () {
        newFromArrayWithCurrentThreadScheduler.subscribe(_next, _error, _complete);
      });
  };