coerce 0.8.11

Async actor runtime and distributed systems framework
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use crate::actor::watch::ActorTerminated;
use crate::actor::{ActorId, BoxedActorRef, Receiver};
use std::collections::HashMap;

#[derive(Default)]
pub struct Watchers {
    watchers: HashMap<ActorId, Receiver<ActorTerminated>>,
}

impl Watchers {
    pub fn iter(&self) -> impl Iterator<Item = &Receiver<ActorTerminated>> {
        self.watchers.values()
    }

    pub fn add_watcher(&mut self, watcher: Receiver<ActorTerminated>) {
        self.watchers.insert(watcher.actor_id().to_owned(), watcher);
    }

    pub fn remove_watcher(&mut self, actor_id: ActorId) {
        self.watchers.remove(&actor_id);
    }
}