/** * Create a sink which enqueues each element into the specified queue. * * @tsplus static effect/core/stream/Sink.Ops fromQueue */ export function fromQueue(queue: Enqueue): Sink { return Sink.forEachChunk((chunk) => queue.offerAll(chunk)) }