1 files changed, 4 insertions, 1 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/observeOn.js b/tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/observeOn.js
index 0a53f78230..a5ad11f8c4 100644
--- a/tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/observeOn.js
+++ b/tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/observeOn.js
@@ -41,16 +41,19 @@ var ObserveOnSubscriber = /*@__PURE__*/ (function (_super) {
         this.unsubscribe();
     };
     ObserveOnSubscriber.prototype.scheduleMessage = function (notification) {
-        this.add(this.scheduler.schedule(ObserveOnSubscriber.dispatch, this.delay, new ObserveOnMessage(notification, this.destination)));
+        var destination = this.destination;
+        destination.add(this.scheduler.schedule(ObserveOnSubscriber.dispatch, this.delay, new ObserveOnMessage(notification, this.destination)));
     };
     ObserveOnSubscriber.prototype._next = function (value) {
         this.scheduleMessage(Notification.createNext(value));
     };
     ObserveOnSubscriber.prototype._error = function (err) {
         this.scheduleMessage(Notification.createError(err));
+        this.unsubscribe();
     };
     ObserveOnSubscriber.prototype._complete = function () {
         this.scheduleMessage(Notification.createComplete());
+        this.unsubscribe();
     };
     return ObserveOnSubscriber;
 }(Subscriber));