Fixing Issue #650

Author: mattpodwysocki

bower.json

@@ -1,6 +1,6 @@
 {
   "name": "rxjs",
-  "version": "2.4.8",
+  "version": "2.4.9",
   "main": [
     "dist/rx.all.js",
     "dist/rx.all.map",

dist/rx.all.compat.js

@@ -1446,7 +1446,7 @@
     return currentScheduler;
   }());
 
-  var scheduleMethod;
+  var scheduleMethod, clearMethod;
 
   var localTimer = (function () {
     var localSetTimeout, localClearTimeout = noop;
@@ -1474,9 +1474,9 @@
 
     var nextHandle = 1, tasksByHandle = {}, currentlyRunning = false;
 
-    function clearMethod(handle) {
+    clearMethod = function (handle) {
       delete tasksByHandle[handle];
-    }
+    };
 
     function runTask(handle) {
       if (currentlyRunning) {
@@ -4739,7 +4739,7 @@
 
     MapObservable.prototype.internalMap = function (selector, thisArg) {
       var self = this;
-      return new MapObservable(this.source, function (x, i, o) { return selector(self.selector(x, i, o), i, o); }, thisArg)
+      return new MapObservable(this.source, function (x, i, o) { return selector.call(this, self.selector(x, i, o), i, o); }, thisArg)
     };
 
     MapObservable.prototype.subscribeCore = function (observer) {
@@ -4765,12 +4765,6 @@
       return this.observer.onError(result.e);
     }
     this.observer.onNext(result);
-    /*try {
-      var result = this.selector(x, this.i++, this.source);
-    } catch (e) {
-      return this.observer.onError(e);
-    }
-    this.observer.onNext(result);*/
   };
   MapObserver.prototype.onError = function (e) {
     if(!this.isStopped) { this.isStopped = true; this.observer.onError(e); }
@@ -5053,7 +5047,7 @@
 
     FilterObservable.prototype.internalFilter = function(predicate, thisArg) {
       var self = this;
-      return new FilterObservable(this.source, function(x, i, o) { return self.predicate(x, i, o) && predicate(x, i, o); }, thisArg);
+      return new FilterObservable(this.source, function(x, i, o) { return self.predicate(x, i, o) && predicate.call(this, x, i, o); }, thisArg);
     };
 
     return FilterObservable;
@@ -9397,9 +9391,12 @@
     }, source);
   };
 
-  observableProto.throttleWithSelector = function () {
+  /**
+   * @deprecated use #debounceWithSelector instead.
+   */
+  observableProto.throttleWithSelector = function (durationSelector) {
     //deprecate('throttleWithSelector', 'debounceWithSelector');
-    return this.debounceWithSelector.apply(this, arguments);
+    return this.debounceWithSelector(durationSelector);
   };
 
   /**

dist/rx.all.compat.map

@@ -1255,7 +1255,7 @@
     return currentScheduler;
   }());
 
-  var scheduleMethod;
+  var scheduleMethod, clearMethod;
 
   var localTimer = (function () {
     var localSetTimeout, localClearTimeout = noop;
@@ -1283,9 +1283,9 @@
 
     var nextHandle = 1, tasksByHandle = {}, currentlyRunning = false;
 
-    function clearMethod(handle) {
+    clearMethod = function (handle) {
       delete tasksByHandle[handle];
-    }
+    };
 
     function runTask(handle) {
       if (currentlyRunning) {
@@ -4594,7 +4594,7 @@
 
     MapObservable.prototype.internalMap = function (selector, thisArg) {
       var self = this;
-      return new MapObservable(this.source, function (x, i, o) { return selector(self.selector(x, i, o), i, o); }, thisArg)
+      return new MapObservable(this.source, function (x, i, o) { return selector.call(this, self.selector(x, i, o), i, o); }, thisArg)
     };
 
     MapObservable.prototype.subscribeCore = function (observer) {
@@ -4620,12 +4620,6 @@
       return this.observer.onError(result.e);
     }
     this.observer.onNext(result);
-    /*try {
-      var result = this.selector(x, this.i++, this.source);
-    } catch (e) {
-      return this.observer.onError(e);
-    }
-    this.observer.onNext(result);*/
   };
   MapObserver.prototype.onError = function (e) {
     if(!this.isStopped) { this.isStopped = true; this.observer.onError(e); }
@@ -4908,7 +4902,7 @@
 
     FilterObservable.prototype.internalFilter = function(predicate, thisArg) {
       var self = this;
-      return new FilterObservable(this.source, function(x, i, o) { return self.predicate(x, i, o) && predicate(x, i, o); }, thisArg);
+      return new FilterObservable(this.source, function(x, i, o) { return self.predicate(x, i, o) && predicate.call(this, x, i, o); }, thisArg);
     };
 
     return FilterObservable;
@@ -9184,9 +9178,12 @@
     }, source);
   };
 
-  observableProto.throttleWithSelector = function () {
+  /**
+   * @deprecated use #debounceWithSelector instead.
+   */
+  observableProto.throttleWithSelector = function (durationSelector) {
     //deprecate('throttleWithSelector', 'debounceWithSelector');
-    return this.debounceWithSelector.apply(this, arguments);
+    return this.debounceWithSelector(durationSelector);
   };
 
   /**

dist/rx.all.compat.min.js

@@ -1446,7 +1446,7 @@
     return currentScheduler;
   }());
 
-  var scheduleMethod;
+  var scheduleMethod, clearMethod;
 
   var localTimer = (function () {
     var localSetTimeout, localClearTimeout = noop;
@@ -1474,9 +1474,9 @@
 
     var nextHandle = 1, tasksByHandle = {}, currentlyRunning = false;
 
-    function clearMethod(handle) {
+    clearMethod = function (handle) {
       delete tasksByHandle[handle];
-    }
+    };
 
     function runTask(handle) {
       if (currentlyRunning) {
@@ -4625,7 +4625,7 @@
 
     MapObservable.prototype.internalMap = function (selector, thisArg) {
       var self = this;
-      return new MapObservable(this.source, function (x, i, o) { return selector(self.selector(x, i, o), i, o); }, thisArg)
+      return new MapObservable(this.source, function (x, i, o) { return selector.call(this, self.selector(x, i, o), i, o); }, thisArg)
     };
 
     MapObservable.prototype.subscribeCore = function (observer) {
@@ -4651,12 +4651,6 @@
       return this.observer.onError(result.e);
     }
     this.observer.onNext(result);
-    /*try {
-      var result = this.selector(x, this.i++, this.source);
-    } catch (e) {
-      return this.observer.onError(e);
-    }
-    this.observer.onNext(result);*/
   };
   MapObserver.prototype.onError = function (e) {
     if(!this.isStopped) { this.isStopped = true; this.observer.onError(e); }
@@ -4939,7 +4933,7 @@
 
     FilterObservable.prototype.internalFilter = function(predicate, thisArg) {
       var self = this;
-      return new FilterObservable(this.source, function(x, i, o) { return self.predicate(x, i, o) && predicate(x, i, o); }, thisArg);
+      return new FilterObservable(this.source, function(x, i, o) { return self.predicate(x, i, o) && predicate.call(this, x, i, o); }, thisArg);
     };
 
     return FilterObservable;