Method sync

packages/effect/src/PubSub.ts:2757–2773

()

    this.remaining = 0
  }
  sync(): void {
    const slides = this.buffer.index - this.slideIndex
    if (slides === 0 || this.remaining === 0) {
      return
    }
    const count = Math.min(slides, this.buffer.capacity)
    const start = this.buffer.index - count
    for (let i = 0; i < count; i++) {
      const entry = this.buffer.slideValues[(start + i) % this.buffer.capacity]
      if (entry.index > this.newestIndex) {
        this.index = (this.index + 1) % this.values.length
        this.values[(this.index + this.remaining - 1) % this.values.length] = entry.value
        this.newestIndex = entry.index
      }
    }
    this.slideIndex = this.buffer.index
  }
  take(): A | undefined {
    if (this.remaining === 0) {
      return undefined