effect-io-ai

Package: effect
Module: Sink

Sink.fromQueue

Create a sink which enqueues each element into the specified queue.

If the shutdown parameter is true, the queue will be shutdown after the sink is evaluated (defaults to false).

Signature

declare const fromQueue: <In>(queue: Queue.Enqueue<In>, options?: { readonly shutdown?: boolean | undefined; }) => Sink<void, In>

Source

Since v2.0.0