fix(forkJoin): catch and forward selector errors

Closes #3216
ReactiveX · 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);
  }