| /** PURE_IMPORTS_START ._Subject,._Subscription PURE_IMPORTS_END */ |
| var __extends = (this && this.__extends) || function (d, b) { |
| for (var p in b) |
| if (b.hasOwnProperty(p)) |
| d[p] = b[p]; |
| function __() { this.constructor = d; } |
| d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __()); |
| }; |
| import { Subject } from './Subject'; |
| import { Subscription } from './Subscription'; |
| /** |
| * @class AsyncSubject<T> |
| */ |
| export var AsyncSubject = /*@__PURE__*/ (/*@__PURE__*/ function (_super) { |
| __extends(AsyncSubject, _super); |
| function AsyncSubject() { |
| _super.apply(this, arguments); |
| this.value = null; |
| this.hasNext = false; |
| this.hasCompleted = false; |
| } |
| AsyncSubject.prototype._subscribe = function (subscriber) { |
| if (this.hasError) { |
| subscriber.error(this.thrownError); |
| return Subscription.EMPTY; |
| } |
| else if (this.hasCompleted && this.hasNext) { |
| subscriber.next(this.value); |
| subscriber.complete(); |
| return Subscription.EMPTY; |
| } |
| return _super.prototype._subscribe.call(this, subscriber); |
| }; |
| AsyncSubject.prototype.next = function (value) { |
| if (!this.hasCompleted) { |
| this.value = value; |
| this.hasNext = true; |
| } |
| }; |
| AsyncSubject.prototype.error = function (error) { |
| if (!this.hasCompleted) { |
| _super.prototype.error.call(this, error); |
| } |
| }; |
| AsyncSubject.prototype.complete = function () { |
| this.hasCompleted = true; |
| if (this.hasNext) { |
| _super.prototype.next.call(this, this.value); |
| } |
| _super.prototype.complete.call(this); |
| }; |
| return AsyncSubject; |
| }(Subject)); |
| //# sourceMappingURL=AsyncSubject.js.map |