We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent b2a27a2 commit f42eed2Copy full SHA for f42eed2
src/Subscriber.ts
@@ -1,6 +1,5 @@
1
import {noop} from './util/noop';
2
import {throwError} from './util/throwError';
3
-import {tryOrOnError} from './util/tryOrOnError';
4
import {tryOrThrowError} from './util/tryOrThrowError';
5
6
import {Observer} from './Observer';
@@ -88,7 +87,7 @@ class SafeSubscriber<T> extends Subscriber<T> {
88
87
error?: (e?: any) => void,
89
complete?: () => void) {
90
super();
91
- this._next = (typeof next === 'function') && tryOrOnError(next) || null;
+ this._next = (typeof next === 'function') && tryOrThrowError(next) || null;
92
this._error = (typeof error === 'function') && tryOrThrowError(error) || throwError;
93
this._complete = (typeof complete === 'function') && tryOrThrowError(complete) || null;
94
}
src/util/tryOrOnError.ts
0 commit comments