aboutsummaryrefslogtreecommitdiff
path: root/tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/repeatWhen.ts
diff options
context:
space:
mode:
Diffstat (limited to 'tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/repeatWhen.ts')
-rw-r--r--tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/repeatWhen.ts9
1 files changed, 5 insertions, 4 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/repeatWhen.ts b/tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/repeatWhen.ts
index d3a6c1c6d8..cd498ef9c5 100644
--- a/tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/repeatWhen.ts
+++ b/tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/repeatWhen.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';
@@ -113,8 +111,11 @@ class RepeatWhenSubscriber<T, R> extends OuterSubscriber<T, R> {
private subscribeToRetries() {
this.notifications = new Subject();
- const retries = tryCatch(this.notifier)(this.notifications);
- if (retries === errorObject) {
+ let retries;
+ try {
+ const { notifier } = this;
+ retries = notifier(this.notifications);
+ } catch (e) {
return super.complete();
}
this.retries = retries;