summaryrefslogtreecommitdiff
path: root/tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/delayWhen.js
diff options
context:
space:
mode:
Diffstat (limited to 'tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/delayWhen.js')
-rw-r--r--tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/delayWhen.js5
1 files changed, 4 insertions, 1 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/delayWhen.js b/tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/delayWhen.js
index 2e045e8725..cda6c7ef24 100644
--- a/tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/delayWhen.js
+++ b/tools/node_modules/eslint/node_modules/rxjs/_esm5/internal/operators/delayWhen.js
@@ -62,6 +62,7 @@ var DelayWhenSubscriber = /*@__PURE__*/ (function (_super) {
DelayWhenSubscriber.prototype._complete = function () {
this.completed = true;
this.tryComplete();
+ this.unsubscribe();
};
DelayWhenSubscriber.prototype.removeSubscription = function (subscription) {
subscription.unsubscribe();
@@ -74,7 +75,8 @@ var DelayWhenSubscriber = /*@__PURE__*/ (function (_super) {
DelayWhenSubscriber.prototype.tryDelay = function (delayNotifier, value) {
var notifierSubscription = subscribeToResult(this, delayNotifier, value);
if (notifierSubscription && !notifierSubscription.closed) {
- this.add(notifierSubscription);
+ var destination = this.destination;
+ destination.add(notifierSubscription);
this.delayNotifierSubscriptions.push(notifierSubscription);
}
};
@@ -115,6 +117,7 @@ var SubscriptionDelaySubscriber = /*@__PURE__*/ (function (_super) {
this.parent.error(err);
};
SubscriptionDelaySubscriber.prototype._complete = function () {
+ this.unsubscribe();
this.subscribeToSource();
};
SubscriptionDelaySubscriber.prototype.subscribeToSource = function () {