Function fromTPubSub

packages/effect/src/internal/stream.ts:3111–3116

(pubsub: TPubSub.TPubSub<A>)

/** @internal */
export const fromTPubSub = <A>(pubsub: TPubSub.TPubSub<A>): Stream.Stream<A> => {
  return unwrapScoped(Effect.map(
    TPubSub.subscribeScoped(pubsub),
    (queue) => fromTQueue(queue)
  ))
}

/** @internal */
export const fromIterable = <A>(iterable: Iterable<A>): Stream.Stream<A> =>