Function unsafeOfferAll

packages/effect/src/internal/pubsub.ts:1300–1302

(queue: MutableQueue.MutableQueue<A>, as: Iterable<A>)

/** @internal */
const unsafeOfferAll = <A>(queue: MutableQueue.MutableQueue<A>, as: Iterable<A>): Chunk.Chunk<A> => {
  return pipe(queue, MutableQueue.offerAll(as))
}

/** @internal */
const unsafePollAllQueue = <A>(queue: MutableQueue.MutableQueue<A>): Chunk.Chunk<A> => {