Queues, PubSub & Background

When to use

• Decoupling producers/consumers with backpressure
• Broadcasting events to multiple subscribers
• Running background loops with graceful shutdown

Queue (bounded)

import { Queue } from "effect"
const q = yield* Queue.bounded<string>(32)
yield* Queue.offer(q, "job")
const job = yield* Queue.take(q)