perf(filter): add fast-path for filtering scalar observables

ReactiveX · Oct 14, 2015 · e2e8954 · e2e8954
1 parent e80bab6
commit e2e8954
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/src/observables/ScalarObservable.ts b/src/observables/ScalarObservable.ts
@@ -62,4 +62,15 @@ export default class ScalarObservable<T> extends Observable<T> {
       return new ScalarObservable(project.call(thisArg || this, this.value, 0));
     }
   }
+
+  filter(select: (x: T, ix?: number) => boolean, thisArg?: any): Observable<T> {
+    let result = tryCatch(select).call(thisArg || this, this.value, 0);
+    if (result === errorObject) {
+      return new ErrorObservable(errorObject.e);
+    } else if (result) {
+      return this;
+    } else {
+      return new EmptyObservable();
+    }
+  }
 }