aector 0.1.1

Dynamic implementation of the actor model with a smart built-in testing framework.
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

use std::sync::{Arc, Mutex};
use std::thread::sleep;
use std::time::Duration;

use tracing_bunyan_formatter::{BunyanFormattingLayer, JsonStorageLayer};
use tracing_log::LogTracer;
use tracing_subscriber::{EnvFilter, Registry};
use tracing_subscriber::layer::SubscriberExt;
use aector::actor::{Actor, MailboxType};
use aector::actor_system::ActorSystem;
use aector::behavior::{Behavior, BehaviorBuilder, BehaviorAction};
use aector::supervision::strategies::SimpleRestartStrategy;


#[tokio::main]
async fn main() {

    type SharedMsg = Arc<Mutex<String>>;
    let mut behavior = BehaviorBuilder::new()
        .on_tell::<SharedMsg>(|msg, state, ctx| -> BehaviorAction<()> {
            let mut str = msg.lock().unwrap();
            str.clear();
            ctx.kill();
            Behavior::keep()
        })
        .build();

    let shared_str = Arc::new(Mutex::new(String::from("hello world!")));
    let actor = Actor::new((), behavior, MailboxType::Unbounded);
    let tx = actor.get_addr();

    let actor_sys = ActorSystem::new();
    actor_sys.spawn(actor,  "actor".to_owned());
    tx.tell(shared_str.clone());
    actor_sys.start().await;
    println!("{}", shared_str.lock().unwrap());
}