sprite-core 0.1.5

Sprite Engine — a fault-tolerant actor runtime for Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

use crate::engine::Engine;
use crate::message::Message;

pub struct Broadcast;

impl Broadcast {
    pub fn all(engine: &Engine, msg: Message) -> usize {
        let channels = engine.inner.channels.read();
        let mut sent = 0;
        for (_, tx) in channels.iter() {
            if tx.send(msg.clone()).is_ok() { sent += 1; }
        }
        sent
    }
}