diff options
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.js | 5 |
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 { |