Lines Matching refs:_events
17 private _events: (ReplayEvent<T> | T)[] = []; property in ReplaySubject
38 const _events = this._events; constant
39 _events.push(value);
42 if (_events.length > this._bufferSize) {
43 _events.shift();
50 this._events.push(new ReplayEvent(this._getNow(), value));
60 const _events = _infiniteTimeWindow ? this._events : this._trimBufferThenGetEvents(); constant
62 const len = _events.length;
80 subscriber.next(<T>_events[i]);
84 subscriber.next((<ReplayEvent<T>>_events[i]).value);
105 const _events = <ReplayEvent<T>[]>this._events; constant
107 const eventsCount = _events.length;
114 if ((now - _events[spliceCount].time) < _windowTime) {
125 _events.splice(0, spliceCount);
128 return _events;