mm1-sup 0.7.22

An Erlang-style actor runtime for Rust.
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
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62

pub mod decider;
pub mod strategy;

mod spec_builder;
mod sup_actor;
mod sup_child;

use std::pin::Pin;
use std::sync::Arc;

use mm1_core::context::{Fork, InitDone, Linking, Messaging, Now, Quit, Start, Stop, Watching};
pub use sup_actor::{MixedSupError, mixed_sup};

use crate::common::factory::ActorFactory;

pub trait MixedSupContext<Runnable>:
    Fork
    + InitDone
    + Linking
    + Messaging
    + Now<Instant = tokio::time::Instant>
    + Quit
    + Start<Runnable>
    + Stop
    + Watching
{
}
impl<Ctx, Runnable> MixedSupContext<Runnable> for Ctx where
    Ctx: Fork
        + InitDone
        + Linking
        + Messaging
        + Now<Instant = tokio::time::Instant>
        + Quit
        + Start<Runnable>
        + Stop
        + Watching
{
}

#[derive(Debug, Clone, Copy)]
pub enum ChildType {
    Permanent,
    Transient,
    Temporary,
}

pub struct MixedSup<RS, C> {
    restart_strategy: RS,
    children:         C,
}

pub type ErasedActorFactory<R> = Pin<Arc<dyn ActorFactory<Args = (), Runnable = R>>>;

impl<RS> MixedSup<RS, ()> {
    pub fn new(restart_strategy: RS) -> Self {
        Self {
            restart_strategy,
            children: (),
        }
    }
}