diff --git a/src/subject/ReplaySubject.ts b/src/subject/ReplaySubject.ts index 2c329e1c31..f50cda0ff6 100644 --- a/src/subject/ReplaySubject.ts +++ b/src/subject/ReplaySubject.ts @@ -9,15 +9,15 @@ export class ReplaySubject extends Subject { private events: ReplayEvent[] = []; private scheduler: Scheduler; private bufferSize: number; - private windowSize: number; + private _windowTime: number; constructor(bufferSize: number = Number.POSITIVE_INFINITY, - windowSize: number = Number.POSITIVE_INFINITY, + windowTime: number = Number.POSITIVE_INFINITY, scheduler?: Scheduler) { super(); this.scheduler = scheduler; this.bufferSize = bufferSize < 1 ? 1 : bufferSize; - this.windowSize = windowSize < 1 ? 1 : windowSize; + this._windowTime = windowTime < 1 ? 1 : windowTime; } protected _next(value: T): void { @@ -49,7 +49,7 @@ export class ReplaySubject extends Subject { private _trimBufferThenGetEvents(now: number): ReplayEvent[] { const bufferSize = this.bufferSize; - const windowSize = this.windowSize; + const _windowTime = this._windowTime; const events = this.events; let eventsCount = events.length; @@ -59,7 +59,7 @@ export class ReplaySubject extends Subject { // 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) < windowSize) { + if ((now - events[spliceCount].time) < _windowTime) { break; } spliceCount += 1;