Function fromPubSubTake

packages/effect/src/Channel.ts:1615–1618

(
  pubsub: PubSub.PubSub<Take.Take<A, E, Done>>
)

 * @since 4.0.0
 */
export const fromPubSubTake = <A, E, Done>(
  pubsub: PubSub.PubSub<Take.Take<A, E, Done>>
): Channel<Arr.NonEmptyReadonlyArray<A>, E, Done> =>
  unwrap(Effect.map(PubSub.subscribe(pubsub), (sub) => fromEffectTake(PubSub.take(sub))))

/**
 * Creates a Channel from a Schedule.