Function fromPubSub

packages/effect/src/Channel.ts:1459–1461

(
  pubsub: PubSub.PubSub<A>
)

 * @since 2.0.0
 */
export const fromPubSub = <A>(
  pubsub: PubSub.PubSub<A>
): Channel<A> => unwrap(Effect.map(PubSub.subscribe(pubsub), fromSubscription))

/**
 * Creates a channel from a PubSub that outputs arrays of values.