sprite_core/broadcast.rs
1use crate::engine::Engine;
2use crate::message::Message;
3
4pub struct Broadcast;
5
6impl Broadcast {
7 pub fn all(engine: &Engine, msg: Message) -> usize {
8 let channels = engine.inner.channels.read();
9 let mut sent = 0;
10 for (_, tx) in channels.iter() {
11 if tx.send(msg.clone()).is_ok() { sent += 1; }
12 }
13 sent
14 }
15}