| /** PURE_IMPORTS_START ._Subject,._scheduler_queue,._Subscription,._operators_observeOn,._util_ObjectUnsubscribedError,._SubjectSubscription 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 { queue } from './scheduler/queue'; |
| import { Subscription } from './Subscription'; |
| import { ObserveOnSubscriber } from './operators/observeOn'; |
| import { ObjectUnsubscribedError } from './util/ObjectUnsubscribedError'; |
| import { SubjectSubscription } from './SubjectSubscription'; |
| /** |
| * @class ReplaySubject<T> |
| */ |
| export var ReplaySubject = /*@__PURE__*/ (/*@__PURE__*/ function (_super) { |
| __extends(ReplaySubject, _super); |
| function ReplaySubject(bufferSize, windowTime, scheduler) { |
| if (bufferSize === void 0) { |
| bufferSize = Number.POSITIVE_INFINITY; |
| } |
| if (windowTime === void 0) { |
| windowTime = Number.POSITIVE_INFINITY; |
| } |
| _super.call(this); |
| this.scheduler = scheduler; |
| this._events = []; |
| this._bufferSize = bufferSize < 1 ? 1 : bufferSize; |
| this._windowTime = windowTime < 1 ? 1 : windowTime; |
| } |
| ReplaySubject.prototype.next = function (value) { |
| var now = this._getNow(); |
| this._events.push(new ReplayEvent(now, value)); |
| this._trimBufferThenGetEvents(); |
| _super.prototype.next.call(this, value); |
| }; |
| ReplaySubject.prototype._subscribe = function (subscriber) { |
| var _events = this._trimBufferThenGetEvents(); |
| var scheduler = this.scheduler; |
| var subscription; |
| if (this.closed) { |
| throw new ObjectUnsubscribedError(); |
| } |
| else if (this.hasError) { |
| subscription = Subscription.EMPTY; |
| } |
| else if (this.isStopped) { |
| subscription = Subscription.EMPTY; |
| } |
| else { |
| this.observers.push(subscriber); |
| subscription = new SubjectSubscription(this, subscriber); |
| } |
| if (scheduler) { |
| subscriber.add(subscriber = new ObserveOnSubscriber(subscriber, scheduler)); |
| } |
| var len = _events.length; |
| for (var i = 0; i < len && !subscriber.closed; i++) { |
| subscriber.next(_events[i].value); |
| } |
| if (this.hasError) { |
| subscriber.error(this.thrownError); |
| } |
| else if (this.isStopped) { |
| subscriber.complete(); |
| } |
| return subscription; |
| }; |
| ReplaySubject.prototype._getNow = function () { |
| return (this.scheduler || queue).now(); |
| }; |
| ReplaySubject.prototype._trimBufferThenGetEvents = function () { |
| var now = this._getNow(); |
| var _bufferSize = this._bufferSize; |
| var _windowTime = this._windowTime; |
| var _events = this._events; |
| var eventsCount = _events.length; |
| var spliceCount = 0; |
| // Trim events that fall out of the time window. |
| // Start at the front of the list. Break early once |
| // we encounter an event that falls within the window. |
| while (spliceCount < eventsCount) { |
| if ((now - _events[spliceCount].time) < _windowTime) { |
| break; |
| } |
| spliceCount++; |
| } |
| if (eventsCount > _bufferSize) { |
| spliceCount = Math.max(spliceCount, eventsCount - _bufferSize); |
| } |
| if (spliceCount > 0) { |
| _events.splice(0, spliceCount); |
| } |
| return _events; |
| }; |
| return ReplaySubject; |
| }(Subject)); |
| var ReplayEvent = /*@__PURE__*/ (/*@__PURE__*/ function () { |
| function ReplayEvent(time, value) { |
| this.time = time; |
| this.value = value; |
| } |
| return ReplayEvent; |
| }()); |
| //# sourceMappingURL=ReplaySubject.js.map |