fix(mergeMap): fix nested mergeMaps

Don't add self as parent. Closes ReactiveX#4071
cartant · Aug 31, 2018 · efa129b · efa129b
1 parent d389e13
commit efa129b
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/internal/Subscriber.ts b/src/internal/Subscriber.ts
@@ -158,7 +158,9 @@ export class Subscriber<T> extends Subscription implements Observer<T> {
 
  /** @deprecated This is an internal implementation detail, do not use. */
  _addParentTeardownLogic(parentTeardownLogic: TeardownLogic) {
- this._parentSubscription = this.add(parentTeardownLogic);
+ if (parentTeardownLogic !== this) {
+ this._parentSubscription = this.add(parentTeardownLogic);
+ }
  }
 
  /** @deprecated This is an internal implementation detail, do not use. */