Fixing Issue #537

Author: mattpodwysocki

dist/rx.all.compat.js

@@ -4423,11 +4423,6 @@
       return new MapObservable(this.source, function (x, i, o) { return selector(self.selector(x, i, o), i, o); }, thisArg)
     };
 
-    MapObservable.prototype.internalMapFilter = function (predicate, thisArg) {
-      var self = this;
-      return new FilterObservable(this.source, function (x, i, o) { return predicate(self.selector(x, i, o), i, o); }, thisArg);
-    };
-
     MapObservable.prototype.subscribeCore = function (observer) {
       return this.source.subscribe(new MapObserver(observer, this.selector, this));
     };
@@ -4763,7 +4758,6 @@
   */
   observableProto.filter = observableProto.where = function (predicate, thisArg) {
     return this instanceof FilterObservable ? this.internalFilter(predicate, thisArg) :
-      this instanceof MapObservable ? this.internalMapFilter(predicate, thisArg) :
       new FilterObservable(this, predicate, thisArg);
   };
 

dist/rx.all.compat.map

@@ -4234,11 +4234,6 @@
       return new MapObservable(this.source, function (x, i, o) { return selector(self.selector(x, i, o), i, o); }, thisArg)
     };
 
-    MapObservable.prototype.internalMapFilter = function (predicate, thisArg) {
-      var self = this;
-      return new FilterObservable(this.source, function (x, i, o) { return predicate(self.selector(x, i, o), i, o); }, thisArg);
-    };
-
     MapObservable.prototype.subscribeCore = function (observer) {
       return this.source.subscribe(new MapObserver(observer, this.selector, this));
     };
@@ -4574,7 +4569,6 @@
   */
   observableProto.filter = observableProto.where = function (predicate, thisArg) {
     return this instanceof FilterObservable ? this.internalFilter(predicate, thisArg) :
-      this instanceof MapObservable ? this.internalMapFilter(predicate, thisArg) :
       new FilterObservable(this, predicate, thisArg);
   };
 

dist/rx.all.compat.min.js

@@ -45,6 +45,7 @@
     observerCreate = Rx.Observer.create,
     addRef = Rx.internals.addRef,
     defaultComparer = Rx.internals.isEqual,
+    inherits = Rx.internals.inherits,
     noop = Rx.helpers.noop,
     identity = Rx.helpers.identity,
     isPromise = Rx.helpers.isPromise,

dist/rx.all.js

@@ -4309,11 +4309,6 @@
       return new MapObservable(this.source, function (x, i, o) { return selector(self.selector(x, i, o), i, o); }, thisArg)
     };
 
-    MapObservable.prototype.internalMapFilter = function (predicate, thisArg) {
-      var self = this;
-      return new FilterObservable(this.source, function (x, i, o) { return predicate(self.selector(x, i, o), i, o); }, thisArg);
-    };
-
     MapObservable.prototype.subscribeCore = function (observer) {
       return this.source.subscribe(new MapObserver(observer, this.selector, this));
     };
@@ -4649,7 +4644,6 @@
   */
   observableProto.filter = observableProto.where = function (predicate, thisArg) {
     return this instanceof FilterObservable ? this.internalFilter(predicate, thisArg) :
-      this instanceof MapObservable ? this.internalMapFilter(predicate, thisArg) :
       new FilterObservable(this, predicate, thisArg);
   };