diff --git a/src/subjects/SubjectSubscription.ts b/src/subjects/SubjectSubscription.ts index 0cb5a20073..6d85fa3ab9 100644 --- a/src/subjects/SubjectSubscription.ts +++ b/src/subjects/SubjectSubscription.ts @@ -1,6 +1,7 @@ import Subject from '../Subject'; import Subscription from '../Subscription'; import Observer from '../Observer'; +import Subscriber from '../Subscriber'; export default class SubjectSubscription extends Subscription { isUnsubscribed: boolean = false; @@ -25,6 +26,9 @@ export default class SubjectSubscription extends Subscription { return; } + if (this.observer instanceof Subscriber) { + (> this.observer).unsubscribe(); + } const subscriberIndex = observers.indexOf(this.observer); if (subscriberIndex !== -1) {