summaryrefslogtreecommitdiff
path: root/tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/operators/onErrorResumeNext.js
diff options
context:
space:
mode:
Diffstat (limited to 'tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/operators/onErrorResumeNext.js')
-rw-r--r--tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/operators/onErrorResumeNext.js5
1 files changed, 4 insertions, 1 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/operators/onErrorResumeNext.js b/tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/operators/onErrorResumeNext.js
index ff940e1591..918b206e76 100644
--- a/tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/operators/onErrorResumeNext.js
+++ b/tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/operators/onErrorResumeNext.js
@@ -39,15 +39,18 @@ class OnErrorResumeNextSubscriber extends OuterSubscriber {
}
_error(err) {
this.subscribeToNextSource();
+ this.unsubscribe();
}
_complete() {
this.subscribeToNextSource();
+ this.unsubscribe();
}
subscribeToNextSource() {
const next = this.nextSources.shift();
if (next) {
const innerSubscriber = new InnerSubscriber(this, undefined, undefined);
- this.add(innerSubscriber);
+ const destination = this.destination;
+ destination.add(innerSubscriber);
subscribeToResult(this, next, undefined, undefined, innerSubscriber);
}
else {