actix 0.4.5

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

extern crate futures;
#[macro_use] extern crate actix;

use std::io::Error;

use actix::prelude::*;
use futures::{future, Future};

#[derive(Message)]
#[rtype(usize, Error)]
struct Sum(usize, usize);

struct SumActor;

impl Actor for SumActor {
    type Context = Context<Self>;
}

impl Handler<Sum> for SumActor {
    type Result = MessageResult<Sum>;

    fn handle(&mut self, message: Sum, _context: &mut Context<Self>) -> Self::Result {
        Ok(message.0 + message.1)
    }
}

#[test]
pub fn response_derive_one() {
    let system = System::new("test");
    let addr: Address<_> = SumActor.start();
    let res = addr.call_fut(Sum(10, 5));
    
    system.handle().spawn(res.then(|res| {
        match res {
            Ok(Ok(result)) => assert!(result == 10 + 5),
            _ => panic!("Something went wrong"),
        }
        
        Arbiter::system().send(actix::msgs::SystemExit(0));
        future::result(Ok(()))
    }));

    system.run();
}