act-zero 0.4.0

Ergonomic actor system
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

//! This example shows how you write a library crate which spawns
//! actors using a runtime provided by the caller.

use act_zero::*;
use futures::executor::LocalPool;
use futures::task::Spawn;

struct HelloWorldActor;

impl Actor for HelloWorldActor {}

impl HelloWorldActor {
    async fn say_hello(&mut self) {
        println!("Hello, world!");
    }
}

async fn run_example(spawner: &impl Spawn) -> Result<(), ActorError> {
    let addr = Addr::new(spawner, HelloWorldActor)?;
    call!(addr.say_hello()).await?;
    Ok(())
}

fn main() -> Result<(), ActorError> {
    let mut pool = LocalPool::new();
    let spawner = pool.spawner();

    pool.run_until(run_example(&spawner))
}