effect-io-ai

Package: effect
Module: Sink

Sink.fromQueue

Creates a sink that offers every consumed input element to a queue.

Details

When the upstream stream ends, the sink ends the queue and completes with void.

Signature

declare const fromQueue: <A>(queue: Queue.Queue<A, Cause.Done>) => Sink<void, A>

Source

Since v2.0.0