1 import { Subscription } from './Subscription';
2 export class SubjectSubscription extends Subscription {
3 constructor(subject, subscriber) {
5 this.subject = subject;
6 this.subscriber = subscriber;
14 const subject = this.subject;
15 const observers = subject.observers;
17 if (!observers || observers.length === 0 || subject.isStopped || subject.closed) {
20 const subscriberIndex = observers.indexOf(this.subscriber);
21 if (subscriberIndex !== -1) {
22 observers.splice(subscriberIndex, 1);
26 //# sourceMappingURL=SubjectSubscription.js.map