📁 File Manager Pro
v10.0.3 | PHP: 8.2.31
Server: LiteSpeed
2026-07-02 06:55:49
📂
/ (Root)
/
home
/
orkouolp
/
web
/
testing.orkobd
/
laravel
/
node_modules
/
rxjs
/
dist
/
esm5
/
internal
📍 /home/orkouolp/web/testing.orkobd/laravel/node_modules/rxjs/dist/esm5/internal
🔄 Refresh
✏️
Editing: AsyncSubject.js
Writable
import { __extends } from "tslib"; import { Subject } from './Subject'; var AsyncSubject = (function (_super) { __extends(AsyncSubject, _super); function AsyncSubject() { var _this = _super !== null && _super.apply(this, arguments) || this; _this._value = null; _this._hasValue = false; _this._isComplete = false; return _this; } AsyncSubject.prototype._checkFinalizedStatuses = function (subscriber) { var _a = this, hasError = _a.hasError, _hasValue = _a._hasValue, _value = _a._value, thrownError = _a.thrownError, isStopped = _a.isStopped, _isComplete = _a._isComplete; if (hasError) { subscriber.error(thrownError); } else if (isStopped || _isComplete) { _hasValue && subscriber.next(_value); subscriber.complete(); } }; AsyncSubject.prototype.next = function (value) { if (!this.isStopped) { this._value = value; this._hasValue = true; } }; AsyncSubject.prototype.complete = function () { var _a = this, _hasValue = _a._hasValue, _value = _a._value, _isComplete = _a._isComplete; if (!_isComplete) { this._isComplete = true; _hasValue && _super.prototype.next.call(this, _value); _super.prototype.complete.call(this); } }; return AsyncSubject; }(Subject)); export { AsyncSubject }; //# sourceMappingURL=AsyncSubject.js.map
💾 Save Changes
❌ Cancel