MCPcopy
hub / github.com/Effect-TS/effect / fromPubSubScoped

Function fromPubSubScoped

packages/effect/src/internal/channel.ts:690–693  ·  view source on GitHub ↗
(
  pubsub: PubSub.PubSub<Either.Either<Elem, Exit.Exit<Done, Err>>>
)

Source from the content-addressed store, hash-verified

688
689/** @internal */
690export const fromPubSubScoped = <Done, Err, Elem>(
691 pubsub: PubSub.PubSub<Either.Either<Elem, Exit.Exit<Done, Err>>>
692): Effect.Effect<Channel.Channel<Elem, unknown, Err, unknown, Done, unknown>, never, Scope.Scope> =>
693 Effect.map(PubSub.subscribe(pubsub), fromQueue)
694
695/** @internal */
696export const fromOption = <A>(

Callers

nothing calls this directly

Calls 2

mapMethod · 0.65
subscribeMethod · 0.65

Tested by

no test coverage detected