diff options
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.js | 5 |
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)); |