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...