fix(exhaustMap): remove innersubscription when it completes

ReactiveX · Feb 27, 2016 · 7ca0859 · 7ca0859
1 parent 9767158
commit 7ca0859
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/operator/exhaustMap.ts b/src/operator/exhaustMap.ts
@@ -1,6 +1,7 @@
 import {Operator} from '../Operator';
 import {Observable, ObservableInput} from '../Observable';
 import {Subscriber} from '../Subscriber';
+import {Subscription} from '../Subscription';
 import {OuterSubscriber} from '../OuterSubscriber';
 import {InnerSubscriber} from '../InnerSubscriber';
 import {subscribeToResult} from '../util/subscribeToResult';
@@ -95,7 +96,9 @@ class SwitchFirstMapSubscriber<T, I, R> extends OuterSubscriber<T, I> {
     this.destination.error(err);
   }
 
-  notifyComplete(): void {
+  notifyComplete(innerSub: Subscription): void {
+    this.remove(innerSub);
+
     this.hasSubscription = false;
     if (this.hasCompleted) {
       this.destination.complete();