Class Broadcast<T>

Example

const broadcast = new Broadcast<number>(5); // Capacity of 5 messages per subscriber

// Subscriber 1
const subscriber1 = broadcast.subscribe();
function listen1() {
    while (!subscriber1.closed) {
        const msg = await subscriber1.receive();
        console.log("Subscriber 1 received:", msg);
    }
}
listen1();

// Subscriber 2
const subscriber2 = broadcast.subscribe();
function listen2() {
    while (!subscriber2.closed) {
        const msg = await subscriber2.receive();
        console.log("Subscriber 2 received:", msg);
    }
}
listen2();

// Send messages
await broadcast.send(1);
await broadcast.send(2);

// Close the broadcast channel
broadcast.close();
Copy