effect-io-ai

Package: effect
Module: Channel

Channel.fromPubSubTake

Subscribes to a PubSub of Take values and exposes them as a channel.

Details

Output Take values are emitted as non-empty arrays. Failed Take values fail the channel. Done Take values complete the channel.

Signature

declare const fromPubSubTake: <A, E, Done>(pubsub: PubSub.PubSub<Take.Take<A, E, Done>>) => Channel<Arr.NonEmptyReadonlyArray<A>, E, Done>

Source

Since v4.0.0