summaryrefslogtreecommitdiff
path: root/tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/delay.js
diff options
context:
space:
mode:
Diffstat (limited to 'tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/delay.js')
-rw-r--r--tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/delay.js5
1 files changed, 4 insertions, 1 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/delay.js b/tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/delay.js
index 48fc38169f..c54ee751e8 100644
--- a/tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/delay.js
+++ b/tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/delay.js
@@ -52,7 +52,8 @@ var DelaySubscriber = /*@__PURE__*/ (function (_super) {
};
DelaySubscriber.prototype._schedule = function (scheduler) {
this.active = true;
- this.add(scheduler.schedule(DelaySubscriber.dispatch, this.delay, {
+ var destination = this.destination;
+ destination.add(scheduler.schedule(DelaySubscriber.dispatch, this.delay, {
source: this, destination: this.destination, scheduler: scheduler
}));
};
@@ -74,9 +75,11 @@ var DelaySubscriber = /*@__PURE__*/ (function (_super) {
this.errored = true;
this.queue = [];
this.destination.error(err);
+ this.unsubscribe();
};
DelaySubscriber.prototype._complete = function () {
this.scheduleNotification(Notification.createComplete());
+ this.unsubscribe();
};
return DelaySubscriber;
}(Subscriber));