Class ReplayWindowImpl

packages/effect/src/internal/pubsub.ts:1710–1755

}

class ReplayWindowImpl<A> implements ReplayWindow<A> {
  head: ReplayNode<A>
  index: number
  remaining: number
  constructor(readonly buffer: ReplayBuffer<A>) {
    this.index = buffer.index
    this.remaining = buffer.size
    this.head = buffer.head
  }
  fastForward() {
    while (this.index < this.buffer.index) {
      this.head = this.head.next!
      this.index++
    }
  }
  take(): A | undefined {
    if (this.remaining === 0) {
      return undefined
    } else if (this.index < this.buffer.index) {
      this.fastForward()
    }
    this.remaining--
    const value = this.head.value
    this.head = this.head.next!
    return value as A
  }
  takeN(n: number): Chunk.Chunk<A> {
    if (this.remaining === 0) {
      return Chunk.empty()
    } else if (this.index < this.buffer.index) {
      this.fastForward()
    }
    const len = Math.min(n, this.remaining)
    const items = new Array(len)
    for (let i = 0; i < len; i++) {
      const value = this.head.value as A
      this.head = this.head.next!
      items[i] = value
    }
    this.remaining -= len
    return Chunk.unsafeFromArray(items)
  }
  takeAll(): Chunk.Chunk<A> {
    return this.takeN(this.remaining)
  }
}

const emptyReplayWindow: ReplayWindow<never> = {
  remaining: 0,