PubSub.bounded for broadcasting
`PubSub` broadcasts messages to all subscribers—unlike Queue, where each value goes to one consumer. Use `PubSub.subscribe` to get a `Dequeue`; use `Queue.take` on that to receive messages. Subscribe before publishing.
- Use `PubSub.bounded<A>(capacity)` to create a PubSub
- Use `PubSub.subscribe(pubsub)` inside Effect.scoped
- Use `Queue.take(dequeue)` on the subscription to receive
Loading code editor...