actix 0.5.7

Actor framework 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

extern crate actix;
extern crate futures;
use futures::{future, Future};

use actix::msgs::{Execute, SystemExit};
use actix::prelude::*;

#[test]
fn test_execute() {
    let sys = System::new("test");
    assert_eq!(Arbiter::name(), "test");

    let addr = Arbiter::new("exec-test");

    Arbiter::handle().spawn(addr.send(Execute::new(|| Ok(Arbiter::name()))).then(
        |res: Result<Result<_, ()>, _>| {
            Arbiter::system().do_send(SystemExit(0));

            match res {
                Ok(Ok(name)) => assert_ne!(name, "test"),
                _ => assert!(false, "something is wrong"),
            }
            future::result(Ok(()))
        },
    ));

    sys.run();
}

#[test]
fn test_system_execute() {
    let sys = System::new("test");
    assert_eq!(Arbiter::name(), "test");

    let addr = Arbiter::new("exec-test");

    addr.do_send(Execute::new(|| -> Result<(), ()> {
        Arbiter::handle().spawn_fn(|| {
            Arbiter::system_arbiter().do_send(Execute::new(|| -> Result<(), ()> {
                Arbiter::system().do_send(SystemExit(0));

                assert_eq!(Arbiter::name(), "test");
                Ok(())
            }));
            future::ok(())
        });
        Ok(())
    }));

    sys.run();
}