( pubsub: PubSub.PubSub<Either.Either<Elem, Exit.Exit<Done, Err>>> )
| 688 | |
| 689 | /** @internal */ |
| 690 | export 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 */ |
| 696 | export const fromOption = <A>( |