Lines Matching refs:_events
17 private _events: (ReplayEvent<T> | T)[] = []; property in ReplaySubject
39 const _events = this._events; constant
40 _events.push(value);
43 if (_events.length > this._bufferSize) {
44 _events.shift();
52 this._events.push(new ReplayEvent(this._getNow(), value));
62 const _events = _infiniteTimeWindow ? this._events : this._trimBufferThenGetEvents(); constant
64 const len = _events.length;
82 subscriber.next(<T>_events[i]);
86 subscriber.next((<ReplayEvent<T>>_events[i]).value);
107 const _events = <ReplayEvent<T>[]>this._events; constant
109 const eventsCount = _events.length;
116 if ((now - _events[spliceCount].time) < _windowTime) {
127 _events.splice(0, spliceCount);
130 return _events;