1 files changed, 4 insertions, 1 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/internal/operators/onErrorResumeNext.js b/tools/node_modules/eslint/node_modules/rxjs/internal/operators/onErrorResumeNext.js
index 7294a5c1c2..f019891bbb 100644
--- a/tools/node_modules/eslint/node_modules/rxjs/internal/operators/onErrorResumeNext.js
+++ b/tools/node_modules/eslint/node_modules/rxjs/internal/operators/onErrorResumeNext.js
@@ -67,15 +67,18 @@ var OnErrorResumeNextSubscriber = (function (_super) {
     };
     OnErrorResumeNextSubscriber.prototype._error = function (err) {
         this.subscribeToNextSource();
+        this.unsubscribe();
     };
     OnErrorResumeNextSubscriber.prototype._complete = function () {
         this.subscribeToNextSource();
+        this.unsubscribe();
     };
     OnErrorResumeNextSubscriber.prototype.subscribeToNextSource = function () {
         var next = this.nextSources.shift();
         if (next) {
             var innerSubscriber = new InnerSubscriber_1.InnerSubscriber(this, undefined, undefined);
-            this.add(innerSubscriber);
+            var destination = this.destination;
+            destination.add(innerSubscriber);
             subscribeToResult_1.subscribeToResult(this, next, undefined, undefined, innerSubscriber);
         }
         else {