fix(filterMap): properly catch errors that could be thrown

staltz · Apr 14, 2016 · 8ff48a5 · 8ff48a5
1 parent 9536978
commit 8ff48a5
Show file tree

Hide file tree

Showing 3 changed files with 19 additions and 3 deletions.
diff --git a/dist/xstream.js b/dist/xstream.js
@@ -688,9 +688,17 @@ var FilterMapOperator = (function () {
         this.ins._remove(this);
         this.out = null;
     };
+    FilterMapOperator.prototype._tryCatch = function (v) {
+        try {
+            this.out._n(this.project(v));
+        }
+        catch (e) {
+            this.out._e(e);
+        }
+    };
     FilterMapOperator.prototype._n = function (v) {
         if (this.predicate(v)) {
-            this.out._n(this.project(v));
+            this._tryCatch(v);
         }
         ;
     };