1 files changed, 5 insertions, 2 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/operators/mergeScan.js b/tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/operators/mergeScan.js
index 8a83a3525d..1fc27ea02d 100644
--- a/tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/operators/mergeScan.js
+++ b/tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/operators/mergeScan.js
@@ -47,7 +47,8 @@ export class MergeScanSubscriber extends OuterSubscriber {
     }
     _innerSub(ish, value, index) {
         const innerSubscriber = new InnerSubscriber(this, undefined, undefined);
-        this.add(innerSubscriber);
+        const destination = this.destination;
+        destination.add(innerSubscriber);
         subscribeToResult(this, ish, value, index, innerSubscriber);
     }
     _complete() {
@@ -58,6 +59,7 @@ export class MergeScanSubscriber extends OuterSubscriber {
             }
             this.destination.complete();
         }
+        this.unsubscribe();
     }
     notifyNext(outerValue, innerValue, outerIndex, innerIndex, innerSub) {
         const { destination } = this;
@@ -67,7 +69,8 @@ export class MergeScanSubscriber extends OuterSubscriber {
     }
     notifyComplete(innerSub) {
         const buffer = this.buffer;
-        this.remove(innerSub);
+        const destination = this.destination;
+        destination.remove(innerSub);
         this.active--;
         if (buffer.length > 0) {
             this._next(buffer.shift());