Sha256: 84fc207fcaacd7525455ef595e5a413be7289a132639984f8dde20bae8700af0
Contents?: true
Size: 915 Bytes
Versions: 49
Compression:
Stored size: 915 Bytes
Contents
import { Subscription } from './Subscription';
/**
* We need this JSDoc comment for affecting ESDoc.
* @ignore
* @extends {Ignored}
*/
export class SubjectSubscription extends Subscription {
constructor(subject, subscriber) {
super();
this.subject = subject;
this.subscriber = subscriber;
this.closed = false;
}
unsubscribe() {
if (this.closed) {
return;
}
this.closed = true;
const subject = this.subject;
const observers = subject.observers;
this.subject = null;
if (!observers || observers.length === 0 || subject.isStopped || subject.closed) {
return;
}
const subscriberIndex = observers.indexOf(this.subscriber);
if (subscriberIndex !== -1) {
observers.splice(subscriberIndex, 1);
}
}
}
//# sourceMappingURL=SubjectSubscription.js.map
Version data entries
49 entries across 49 versions & 4 rubygems