We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent e80bab6 commit e2e8954Copy full SHA for e2e8954
src/observables/ScalarObservable.ts
@@ -62,4 +62,15 @@ export default class ScalarObservable<T> extends Observable<T> {
62
return new ScalarObservable(project.call(thisArg || this, this.value, 0));
63
}
64
65
+
66
+ filter(select: (x: T, ix?: number) => boolean, thisArg?: any): Observable<T> {
67
+ let result = tryCatch(select).call(thisArg || this, this.value, 0);
68
+ if (result === errorObject) {
69
+ return new ErrorObservable(errorObject.e);
70
+ } else if (result) {
71
+ return this;
72
+ } else {
73
+ return new EmptyObservable();
74
+ }
75
76
0 commit comments