blob: b7a71a240f3308ef36b974fd52f706d02c9afdef (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
|
import { Subject } from './Subject';
export class AsyncSubject extends Subject {
constructor() {
super(...arguments);
this._value = null;
this._hasValue = false;
this._isComplete = false;
}
_checkFinalizedStatuses(subscriber) {
const { hasError, _hasValue, _value, thrownError, isStopped, _isComplete } = this;
if (hasError) {
subscriber.error(thrownError);
}
else if (isStopped || _isComplete) {
_hasValue && subscriber.next(_value);
subscriber.complete();
}
}
next(value) {
if (!this.isStopped) {
this._value = value;
this._hasValue = true;
}
}
complete() {
const { _hasValue, _value, _isComplete } = this;
if (!_isComplete) {
this._isComplete = true;
_hasValue && super.next(_value);
super.complete();
}
}
}
//# sourceMappingURL=AsyncSubject.js.map
|
