Sha256: c3d85c4d4dfb23b334ad0a69d84e11128478334de7264b3f40b40839d531771d
Contents?: true
Size: 950 Bytes
Versions: 49
Compression:
Stored size: 950 Bytes
Contents
import { Subject } from './Subject';
import { ObjectUnsubscribedError } from './util/ObjectUnsubscribedError';
/**
* @class BehaviorSubject<T>
*/
export class BehaviorSubject extends Subject {
constructor(_value) {
super();
this._value = _value;
}
get value() {
return this.getValue();
}
/** @deprecated internal use only */ _subscribe(subscriber) {
const subscription = super._subscribe(subscriber);
if (subscription && !subscription.closed) {
subscriber.next(this._value);
}
return subscription;
}
getValue() {
if (this.hasError) {
throw this.thrownError;
}
else if (this.closed) {
throw new ObjectUnsubscribedError();
}
else {
return this._value;
}
}
next(value) {
super.next(this._value = value);
}
}
//# sourceMappingURL=BehaviorSubject.js.map
Version data entries
49 entries across 49 versions & 4 rubygems