/** * Creates a stream from a `TQueue` of values. * * @tsplus static effect/core/stream/Stream.Ops fromTQueue */ export function fromTQueue(queue: TQueue): Stream { return Stream.repeatEffectChunk(queue.take.map(Chunk.single).commit) }