fix(forkJoin): catch and forward selector errors

Closes ReactiveX#3216
cartant · Jan 26, 2018 · c96f4d2 · c96f4d2
1 parent ea10cd4
commit c96f4d2
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/src/internal/observable/ForkJoinObservable.ts b/src/internal/observable/ForkJoinObservable.ts
@@ -224,7 +224,13 @@ class ForkJoinSubscriber<T> extends OuterSubscriber<T, T> {
     }
 
     if (haveValues === len) {
-      const value = resultSelector ? resultSelector.apply(this, values) : values;
+      let value: any;
+      try {
+        value = resultSelector ? resultSelector.apply(this, values) : values;
+      } catch (err) {
+        destination.error(err);
+        return;
+      }
       destination.next(value);
     }