effect-io-ai

Package: effect
Module: Stream

Stream.fromChunkPubSub

Creates a stream from a subscription to a PubSub.

Options

• shutdown: If true, the PubSub will be shutdown after the stream is evaluated (defaults to false)

Signature

declare const fromChunkPubSub: { <A>(pubsub: PubSub.PubSub<Chunk.Chunk<A>>, options: { readonly scoped: true; readonly shutdown?: boolean | undefined; }): Effect.Effect<Stream<A>, never, Scope.Scope>; <A>(pubsub: PubSub.PubSub<Chunk.Chunk<A>>, options?: { readonly scoped?: false | undefined; readonly shutdown?: boolean | undefined; } | undefined): Stream<A>; }

Source

Since v2.0.0