aboutsummaryrefslogtreecommitdiff
path: root/tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/retryWhen.ts
diff options
context:
space:
mode:
Diffstat (limited to 'tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/retryWhen.ts')
-rw-r--r--tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/retryWhen.ts10
1 files changed, 5 insertions, 5 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/retryWhen.ts b/tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/retryWhen.ts
index 3c2ef6e559..325742dcb6 100644
--- a/tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/retryWhen.ts
+++ b/tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/retryWhen.ts
@@ -3,8 +3,6 @@ import { Subscriber } from '../Subscriber';
import { Observable } from '../Observable';
import { Subject } from '../Subject';
import { Subscription } from '../Subscription';
-import { tryCatch } from '../util/tryCatch';
-import { errorObject } from '../util/errorObject';
import { OuterSubscriber } from '../OuterSubscriber';
import { InnerSubscriber } from '../InnerSubscriber';
@@ -66,9 +64,11 @@ class RetryWhenSubscriber<T, R> extends OuterSubscriber<T, R> {
if (!retries) {
errors = new Subject();
- retries = tryCatch(this.notifier)(errors);
- if (retries === errorObject) {
- return super.error(errorObject.e);
+ try {
+ const { notifier } = this;
+ retries = notifier(errors);
+ } catch (e) {
+ return super.error(e);
}
retriesSubscription = subscribeToResult(this, retries);
} else {