effect-io-ai

Package: effect
Module: Sink

Sink.fromPubSub

Create a sink which publishes each element to the specified PubSub.

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

Signature

declare const fromPubSub: <In>(pubsub: PubSub.PubSub<In>, options?: { readonly shutdown?: boolean | undefined; }) => Sink<void, In>

Source

Since v2.0.0