Reactive-Extensions · mattpodwysocki · Jan 7, 2015 · Jan 7, 2015 · Jan 7, 2015
diff --git a/dist/rx.all.compat.js b/dist/rx.all.compat.js
@@ -2230,7 +2230,7 @@
             oldOnError(err);
           };
 
-          return subscribe(observer);
+          return subscribe.call(self, observer);
         };
       } else {
         this._subscribe = subscribe;

diff --git a/dist/rx.all.compat.map b/dist/rx.all.compat.map
diff --git a/dist/rx.all.compat.min.js b/dist/rx.all.compat.min.js
diff --git a/dist/rx.all.js b/dist/rx.all.js
@@ -2041,7 +2041,7 @@
             oldOnError(err);
           };
 
-          return subscribe(observer);
+          return subscribe.call(self, observer);
         };
       } else {
         this._subscribe = subscribe;

diff --git a/dist/rx.all.map b/dist/rx.all.map
diff --git a/dist/rx.all.min.js b/dist/rx.all.min.js
diff --git a/dist/rx.compat.js b/dist/rx.compat.js
@@ -2230,7 +2230,7 @@
             oldOnError(err);
           };
 
-          return subscribe(observer);
+          return subscribe.call(self, observer);
         };
       } else {
         this._subscribe = subscribe;

diff --git a/dist/rx.compat.map b/dist/rx.compat.map
diff --git a/dist/rx.compat.min.js b/dist/rx.compat.min.js
diff --git a/dist/rx.js b/dist/rx.js
@@ -2041,7 +2041,7 @@
             oldOnError(err);
           };
 
-          return subscribe(observer);
+          return subscribe.call(self, observer);
         };
       } else {
         this._subscribe = subscribe;

diff --git a/dist/rx.lite.compat.js b/dist/rx.lite.compat.js
@@ -1964,7 +1964,7 @@
             oldOnError(err);
           };
 
-          return subscribe(observer);
+          return subscribe.call(self, observer);
         };
       } else {
         this._subscribe = subscribe;

diff --git a/dist/rx.lite.compat.map b/dist/rx.lite.compat.map
diff --git a/dist/rx.lite.compat.min.js b/dist/rx.lite.compat.min.js
diff --git a/dist/rx.lite.js b/dist/rx.lite.js
@@ -1775,7 +1775,7 @@
             oldOnError(err);
           };
 
-          return subscribe(observer);
+          return subscribe.call(self, observer);
         };
       } else {
         this._subscribe = subscribe;

diff --git a/dist/rx.lite.map b/dist/rx.lite.map
diff --git a/dist/rx.lite.min.js b/dist/rx.lite.min.js
diff --git a/dist/rx.map b/dist/rx.map
diff --git a/dist/rx.min.js b/dist/rx.min.js
diff --git a/src/core/observable.js b/src/core/observable.js
@@ -22,7 +22,7 @@
             oldOnError(err);
           };
 
-          return subscribe(observer);
+          return subscribe.call(self, observer);
         };
       } else {
         this._subscribe = subscribe;