effect-io-ai

Package: effect
Module: Stream

Stream.fromChunkQueue

Creates a stream from a Queue of values.

Options

• shutdown: If true, the queue will be shutdown after the stream is evaluated (defaults to false)

Signature

declare const fromChunkQueue: <A>(queue: Queue.Dequeue<Chunk.Chunk<A>>, options?: { readonly shutdown?: boolean | undefined; }) => Stream<A>

Source

Since v2.0.0