test(forkJoin): add selector error test

cartant · Jan 26, 2018 · ea10cd4 · ea10cd4
1 parent 6a4ace4
commit ea10cd4
Showing 1 changed file with 14 additions and 0 deletions.
diff --git a/spec/observables/forkJoin-spec.ts b/spec/observables/forkJoin-spec.ts
@@ -331,6 +331,20 @@ describe('Observable.forkJoin', () => {
     expectObservable(e1).toBe(expected);
   });
 
+  it('should raise error when the selector throws', () => {
+    function selector(x, y) {
+      throw 'error';
+    }
+
+    const e1 = Observable.forkJoin(
+               hot('--a-|'),
+               hot('---b-|'),
+               selector);
+    const expected = '-----#';
+
+    expectObservable(e1).toBe(expected);
+  });
+
   it('should allow unsubscribing early and explicitly', () => {
     const e1 =   hot('--a--^--b--c---d-| ');
     const e1subs =        '^        !    ';