1 files changed, 5 insertions, 2 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/internal/operators/exhaustMap.js b/tools/node_modules/eslint/node_modules/rxjs/internal/operators/exhaustMap.js
index e0b0a90e37..e30bc63b83 100644
--- a/tools/node_modules/eslint/node_modules/rxjs/internal/operators/exhaustMap.js
+++ b/tools/node_modules/eslint/node_modules/rxjs/internal/operators/exhaustMap.js
@@ -66,7 +66,8 @@ var ExhaustMapSubscriber = (function (_super) {
     };
     ExhaustMapSubscriber.prototype._innerSub = function (result, 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, result, value, index, innerSubscriber);
     };
     ExhaustMapSubscriber.prototype._complete = function () {
@@ -74,6 +75,7 @@ var ExhaustMapSubscriber = (function (_super) {
         if (!this.hasSubscription) {
             this.destination.complete();
         }
+        this.unsubscribe();
     };
     ExhaustMapSubscriber.prototype.notifyNext = function (outerValue, innerValue, outerIndex, innerIndex, innerSub) {
         this.destination.next(innerValue);
@@ -82,7 +84,8 @@ var ExhaustMapSubscriber = (function (_super) {
         this.destination.error(err);
     };
     ExhaustMapSubscriber.prototype.notifyComplete = function (innerSub) {
-        this.remove(innerSub);
+        var destination = this.destination;
+        destination.remove(innerSub);
         this.hasSubscription = false;
         if (this.hasCompleted) {
             this.destination.complete();