Method offerAll

packages/effect/src/PubSub.ts:2726–2730

(as: Iterable<A>)

    return index
  }
  offerAll(as: Iterable<A>): void {
    for (const a of as) {
      this.offer(a)
    }
  }
}

class ReplayWindowImpl<A> implements PubSub.ReplayWindow<A> {