test(Observable): add failing test for syncErrorThrowable issue

ReactiveX · Dec 5, 2017 · c498974 · c498974
1 parent 520b06a
commit c498974
Showing 1 changed file with 14 additions and 0 deletions.
diff --git a/spec/Observable-spec.ts b/spec/Observable-spec.ts
@@ -59,6 +59,20 @@ describe('Observable', () => {
     }).to.throw();
   });
 
+  it('should rethrow if sink has syncErrorThrowable = false', () => {
+    const observable = new Observable(observer => {
+      observer.next(1);
+    });
+
+    const sink = Subscriber.create(() => {
+      throw 'error!';
+    });
+
+    expect(() => {
+      observable.subscribe(sink);
+    }).to.throw('error!');
+  });
+
   describe('forEach', () => {
     it('should iterate and return a Promise', (done: MochaDone) => {
       const expected = [1, 2, 3];