summaryrefslogtreecommitdiff
path: root/tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/switchMap.ts
diff options
context:
space:
mode:
Diffstat (limited to 'tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/switchMap.ts')
-rw-r--r--tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/switchMap.ts7
1 files changed, 5 insertions, 2 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/switchMap.ts b/tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/switchMap.ts
index ee83978c08..0008c379ef 100644
--- a/tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/switchMap.ts
+++ b/tools/node_modules/eslint/node_modules/rxjs/src/internal/operators/switchMap.ts
@@ -114,7 +114,8 @@ class SwitchMapSubscriber<T, R> extends OuterSubscriber<T, R> {
innerSubscription.unsubscribe();
}
const innerSubscriber = new InnerSubscriber(this, undefined, undefined);
- this.add(innerSubscriber);
+ const destination = this.destination as Subscription;
+ destination.add(innerSubscriber);
this.innerSubscription = subscribeToResult(this, result, value, index, innerSubscriber);
}
@@ -123,6 +124,7 @@ class SwitchMapSubscriber<T, R> extends OuterSubscriber<T, R> {
if (!innerSubscription || innerSubscription.closed) {
super._complete();
}
+ this.unsubscribe();
}
protected _unsubscribe() {
@@ -130,7 +132,8 @@ class SwitchMapSubscriber<T, R> extends OuterSubscriber<T, R> {
}
notifyComplete(innerSub: Subscription): void {
- this.remove(innerSub);
+ const destination = this.destination as Subscription;
+ destination.remove(innerSub);
this.innerSubscription = null;
if (this.isStopped) {
super._complete();