xtor 0.9.10

Async Actor framework for Rust which is blazing fast and rock solid.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

use crate::actor::{
    addr::Addr,
    message::{Handler, Message},
    runner::{Actor, ActorID},
};

/// The supervisor is responsible for restarting actors.
/// enable feature "supervisor_catch_unwind" for catch normal panics
/// it will slow down the program but it is more safe
/// **supervisor must hold the address of the supervised actor!!**
#[async_trait::async_trait]
pub trait Supervisor: Actor + Handler<Restart> + Handler<Supervise> {}

pub struct Restart(pub ActorID);
impl Message for Restart {
    type Result = anyhow::Result<()>;
}

pub struct Supervise(pub Addr);
impl Message for Supervise {
    type Result = ();
}

pub struct Unsupervise(pub Addr);
impl Message for Unsupervise {
    type Result = ();
}