Skip to content

Commit 7ca0859

Browse files
committed
fix(exhaustMap): remove innersubscription when it completes
1 parent 9767158 commit 7ca0859

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

src/operator/exhaustMap.ts

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
import {Operator} from '../Operator';
22
import {Observable, ObservableInput} from '../Observable';
33
import {Subscriber} from '../Subscriber';
4+
import {Subscription} from '../Subscription';
45
import {OuterSubscriber} from '../OuterSubscriber';
56
import {InnerSubscriber} from '../InnerSubscriber';
67
import {subscribeToResult} from '../util/subscribeToResult';
@@ -95,7 +96,9 @@ class SwitchFirstMapSubscriber<T, I, R> extends OuterSubscriber<T, I> {
9596
this.destination.error(err);
9697
}
9798

98-
notifyComplete(): void {
99+
notifyComplete(innerSub: Subscription): void {
100+
this.remove(innerSub);
101+
99102
this.hasSubscription = false;
100103
if (this.hasCompleted) {
101104
this.destination.complete();

0 commit comments

Comments
 (0)