| /** PURE_IMPORTS_START tslib,_Subject,_scheduler_queue,_Subscription,_operators_observeOn,_util_ObjectUnsubscribedError,_SubjectSubscription PURE_IMPORTS_END */ |
| import * as tslib_1 from "tslib"; |
| 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'; |
| var ReplaySubject = /*@__PURE__*/ (function (_super) { |
| tslib_1.__extends(ReplaySubject, _super); |
| function ReplaySubject(bufferSize, windowTime, scheduler) { |
| if (bufferSize === void 0) { |
| bufferSize = Number.POSITIVE_INFINITY; |
| } |
| if (windowTime === void 0) { |
| windowTime = Number.POSITIVE_INFINITY; |
| } |
| var _this = _super.call(this) || this; |
| _this.scheduler = scheduler; |
| _this._events = []; |
| _this._infiniteTimeWindow = false; |
| _this._bufferSize = bufferSize < 1 ? 1 : bufferSize; |
| _this._windowTime = windowTime < 1 ? 1 : windowTime; |
| if (windowTime === Number.POSITIVE_INFINITY) { |
| _this._infiniteTimeWindow = true; |
| _this.next = _this.nextInfiniteTimeWindow; |
| } |
| else { |
| _this.next = _this.nextTimeWindow; |
| } |
| return _this; |
| } |
| ReplaySubject.prototype.nextInfiniteTimeWindow = function (value) { |
| var _events = this._events; |
| _events.push(value); |
| if (_events.length > this._bufferSize) { |
| _events.shift(); |
| } |
| _super.prototype.next.call(this, value); |
| }; |
| ReplaySubject.prototype.nextTimeWindow = function (value) { |
| this._events.push(new ReplayEvent(this._getNow(), value)); |
| this._trimBufferThenGetEvents(); |
| _super.prototype.next.call(this, value); |
| }; |
| ReplaySubject.prototype._subscribe = function (subscriber) { |
| var _infiniteTimeWindow = this._infiniteTimeWindow; |
| var _events = _infiniteTimeWindow ? this._events : this._trimBufferThenGetEvents(); |
| var scheduler = this.scheduler; |
| var len = _events.length; |
| var subscription; |
| if (this.closed) { |
| throw new ObjectUnsubscribedError(); |
| } |
| else if (this.isStopped || this.hasError) { |
| subscription = Subscription.EMPTY; |
| } |
| else { |
| this.observers.push(subscriber); |
| subscription = new SubjectSubscription(this, subscriber); |
| } |
| if (scheduler) { |
| subscriber.add(subscriber = new ObserveOnSubscriber(subscriber, scheduler)); |
| } |
| if (_infiniteTimeWindow) { |
| for (var i = 0; i < len && !subscriber.closed; i++) { |
| subscriber.next(_events[i]); |
| } |
| } |
| else { |
| 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; |
| 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)); |
| export { ReplaySubject }; |
| var ReplayEvent = /*@__PURE__*/ (function () { |
| function ReplayEvent(time, value) { |
| this.time = time; |
| this.value = value; |
| } |
| return ReplayEvent; |
| }()); |
| //# sourceMappingURL=ReplaySubject.js.map |