actix 0.3.2

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
52
53
54
55

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

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


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

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

    Arbiter::handle().spawn(
        addr.call_fut(Execute::new(|| {
            Ok(Arbiter::name())
        })).then(|res: Result<Result<_, ()>, _>| {
            Arbiter::system().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.send(Execute::new(
        || -> Result<(), ()> {
            Arbiter::handle().spawn_fn(|| {
                Arbiter::system_arbiter().send(Execute::new(|| -> Result<(), ()> {
                    Arbiter::system().send(SystemExit(0));

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

    sys.run();
}