fix(Subscriber): creates safesubscriber for internal subscribers

- closes #2813
ReactiveX · Sep 25, 2017 · 0f59314 · 0f59314
1 parent 2e576dc
commit 0f59314
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/Subscriber.ts b/src/Subscriber.ts
@@ -67,7 +67,7 @@ export class Subscriber<T> extends Subscription implements Observer<T> {
  break;
  }
  if (typeof destinationOrNext === 'object') {
- if (destinationOrNext instanceof Subscriber) {
+ if (destinationOrNext instanceof SafeSubscriber) {
  this.destination = (<Subscriber<any>> destinationOrNext);
  (<any> this.destination).add(this);
  } else {