effect-io-ai

Package: effect
Module: Sink

Sink.fromPubSub

Creates a sink that publishes every consumed input element to a PubSub.

Details

The sink completes with void when the upstream stream ends.

Signature

declare const fromPubSub: <A>(pubsub: PubSub.PubSub<A>) => Sink<void, A>

Source

Since v2.0.0