Fixing Issue #843

Author: mattpodwysocki

dist/rx.all.compat.js

@@ -6489,6 +6489,8 @@ function createCbHandler(o, ctx, selector) {
  */
 Observable.fromCallback = function (fn, ctx, selector) {
   return function () {
+    typeof ctx === 'undefined' && (ctx = this); 
+
     var len = arguments.length, args = new Array(len)
     for(var i = 0; i < len; i++) { args[i] = arguments[i]; }
     return createCbObservable(fn, ctx, selector, args);
@@ -6537,6 +6539,7 @@ function createNodeHandler(o, ctx, selector) {
  */
 Observable.fromNodeCallback = function (fn, ctx, selector) {
   return function () {
+    typeof ctx === 'undefined' && (ctx = this); 
     var len = arguments.length, args = new Array(len);
     for(var i = 0; i < len; i++) { args[i] = arguments[i]; }
     return createNodeObservable(fn, ctx, selector, args);

dist/rx.all.compat.map

@@ -6387,6 +6387,8 @@ function createCbHandler(o, ctx, selector) {
  */
 Observable.fromCallback = function (fn, ctx, selector) {
   return function () {
+    typeof ctx === 'undefined' && (ctx = this); 
+
     var len = arguments.length, args = new Array(len)
     for(var i = 0; i < len; i++) { args[i] = arguments[i]; }
     return createCbObservable(fn, ctx, selector, args);
@@ -6435,6 +6437,7 @@ function createNodeHandler(o, ctx, selector) {
  */
 Observable.fromNodeCallback = function (fn, ctx, selector) {
   return function () {
+    typeof ctx === 'undefined' && (ctx = this); 
     var len = arguments.length, args = new Array(len);
     for(var i = 0; i < len; i++) { args[i] = arguments[i]; }
     return createNodeObservable(fn, ctx, selector, args);

dist/rx.all.compat.min.js

@@ -268,6 +268,8 @@ function createCbHandler(o, ctx, selector) {
  */
 Observable.fromCallback = function (fn, ctx, selector) {
   return function () {
+    typeof ctx === 'undefined' && (ctx = this); 
+
     var len = arguments.length, args = new Array(len)
     for(var i = 0; i < len; i++) { args[i] = arguments[i]; }
     return createCbObservable(fn, ctx, selector, args);
@@ -316,6 +318,7 @@ function createNodeHandler(o, ctx, selector) {
  */
 Observable.fromNodeCallback = function (fn, ctx, selector) {
   return function () {
+    typeof ctx === 'undefined' && (ctx = this); 
     var len = arguments.length, args = new Array(len);
     for(var i = 0; i < len; i++) { args[i] = arguments[i]; }
     return createNodeObservable(fn, ctx, selector, args);

dist/rx.all.js

@@ -268,6 +268,8 @@ function createCbHandler(o, ctx, selector) {
  */
 Observable.fromCallback = function (fn, ctx, selector) {
   return function () {
+    typeof ctx === 'undefined' && (ctx = this); 
+
     var len = arguments.length, args = new Array(len)
     for(var i = 0; i < len; i++) { args[i] = arguments[i]; }
     return createCbObservable(fn, ctx, selector, args);
@@ -316,6 +318,7 @@ function createNodeHandler(o, ctx, selector) {
  */
 Observable.fromNodeCallback = function (fn, ctx, selector) {
   return function () {
+    typeof ctx === 'undefined' && (ctx = this); 
     var len = arguments.length, args = new Array(len);
     for(var i = 0; i < len; i++) { args[i] = arguments[i]; }
     return createNodeObservable(fn, ctx, selector, args);