1 files changed, 5 insertions, 2 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/operators/exhaustMap.js b/tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/operators/exhaustMap.js
index 027438bebb..c856afb19d 100644
--- a/tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/operators/exhaustMap.js
+++ b/tools/node_modules/eslint/node_modules/rxjs/_esm2015/internal/operators/exhaustMap.js
@@ -45,7 +45,8 @@ class ExhaustMapSubscriber extends OuterSubscriber {
     }
     _innerSub(result, value, index) {
         const innerSubscriber = new InnerSubscriber(this, undefined, undefined);
-        this.add(innerSubscriber);
+        const destination = this.destination;
+        destination.add(innerSubscriber);
         subscribeToResult(this, result, value, index, innerSubscriber);
     }
     _complete() {
@@ -53,6 +54,7 @@ class ExhaustMapSubscriber extends OuterSubscriber {
         if (!this.hasSubscription) {
             this.destination.complete();
         }
+        this.unsubscribe();
     }
     notifyNext(outerValue, innerValue, outerIndex, innerIndex, innerSub) {
         this.destination.next(innerValue);
@@ -61,7 +63,8 @@ class ExhaustMapSubscriber extends OuterSubscriber {
         this.destination.error(err);
     }
     notifyComplete(innerSub) {
-        this.remove(innerSub);
+        const destination = this.destination;
+        destination.remove(innerSub);
         this.hasSubscription = false;
         if (this.hasCompleted) {
             this.destination.complete();