1 files changed, 5 insertions, 2 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/internal/operators/mergeScan.js b/tools/node_modules/eslint/node_modules/rxjs/internal/operators/mergeScan.js
index 689c60c962..189188489a 100644
--- a/tools/node_modules/eslint/node_modules/rxjs/internal/operators/mergeScan.js
+++ b/tools/node_modules/eslint/node_modules/rxjs/internal/operators/mergeScan.js
@@ -68,7 +68,8 @@ var MergeScanSubscriber = (function (_super) {
     };
     MergeScanSubscriber.prototype._innerSub = function (ish, value, index) {
         var innerSubscriber = new InnerSubscriber_1.InnerSubscriber(this, undefined, undefined);
-        this.add(innerSubscriber);
+        var destination = this.destination;
+        destination.add(innerSubscriber);
         subscribeToResult_1.subscribeToResult(this, ish, value, index, innerSubscriber);
     };
     MergeScanSubscriber.prototype._complete = function () {
@@ -79,6 +80,7 @@ var MergeScanSubscriber = (function (_super) {
             }
             this.destination.complete();
         }
+        this.unsubscribe();
     };
     MergeScanSubscriber.prototype.notifyNext = function (outerValue, innerValue, outerIndex, innerIndex, innerSub) {
         var destination = this.destination;
@@ -88,7 +90,8 @@ var MergeScanSubscriber = (function (_super) {
     };
     MergeScanSubscriber.prototype.notifyComplete = function (innerSub) {
         var buffer = this.buffer;
-        this.remove(innerSub);
+        var destination = this.destination;
+        destination.remove(innerSub);
         this.active--;
         if (buffer.length > 0) {
             this._next(buffer.shift());