diff options
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.ts | 10 |
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 { |