Method since

src/workspaces/replay-buffer.ts:57–79

(seq: number)

  }

  since(seq: number): ReplaySlice {
    const effectiveSeq = Math.max(seq, this.head);
    const tailSeq = this.tailSeq;
    if (effectiveSeq >= tailSeq) {
      return { bytes: EMPTY, effectiveSeq, tailSeq };
    }
    const skipBytes = effectiveSeq - this.head;
    const out: Buffer[] = [];
    let remainingSkip = skipBytes;
    for (const chunk of this.chunks) {
      if (remainingSkip >= chunk.length) {
        remainingSkip -= chunk.length;
        continue;
      }
      if (remainingSkip > 0) {
        out.push(chunk.subarray(remainingSkip));
        remainingSkip = 0;
      } else {
        out.push(chunk);
      }
    }
    return { bytes: Buffer.concat(out), effectiveSeq, tailSeq };
  }

  private evict(): void {
    while (this.totalBytes > this.maxBytes) {