Function fromPubSubArray

packages/effect/src/Channel.ts:1601–1602

(pubsub: PubSub.PubSub<A>)

 * @since 4.0.0
 */
export const fromPubSubArray = <A>(pubsub: PubSub.PubSub<A>): Channel<Arr.NonEmptyReadonlyArray<A>> =>
  unwrap(Effect.map(PubSub.subscribe(pubsub), fromSubscriptionArray))

/**
 * Subscribes to a `PubSub` of `Take` values and exposes them as a channel.