fix(Subscriber): errors in nextHandler no longer propagate to errorHa…

…ndler fixes #1135
ReactiveX · Jan 13, 2016 · f42eed2 · f42eed2
1 parent b2a27a2
commit f42eed2
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 13 deletions.
diff --git a/src/Subscriber.ts b/src/Subscriber.ts
@@ -1,6 +1,5 @@
 import {noop} from './util/noop';
 import {throwError} from './util/throwError';
-import {tryOrOnError} from './util/tryOrOnError';
 import {tryOrThrowError} from './util/tryOrThrowError';
 
 import {Observer} from './Observer';
@@ -88,7 +87,7 @@ class SafeSubscriber<T> extends Subscriber<T> {
               error?: (e?: any) => void,
               complete?: () => void) {
     super();
-    this._next = (typeof next === 'function') && tryOrOnError(next) || null;
+    this._next = (typeof next === 'function') && tryOrThrowError(next) || null;
     this._error = (typeof error === 'function') && tryOrThrowError(error) || throwError;
     this._complete = (typeof complete === 'function') && tryOrThrowError(complete) || null;
   }

diff --git a/src/util/tryOrOnError.ts b/src/util/tryOrOnError.ts