effect-io-ai

Package: effect
Module: Channel

Channel.fromPubSub

Construct a Channel from a PubSub.

Signature

declare const fromPubSub: <Done, Err, Elem>(pubsub: PubSub.PubSub<Either.Either<Elem, Exit.Exit<Done, Err>>>) => Channel<Elem, unknown, Err, unknown, Done, unknown>

Source

Since v2.0.0