request_response/
request_response.rs

1use tractor::prelude::*;
2
3enum MyActorMsg {
4    Add(usize, usize),
5    AddedResult(usize),
6}
7
8enum AdderMsg {
9    Add {
10        a: usize,
11        b: usize,
12        respond: Chan<MyActorMsg>,
13    },
14}
15
16struct MyActor {
17    adder: Chan<AdderMsg>,
18}
19
20impl Actor for MyActor {
21    type Msg = MyActorMsg;
22}
23
24impl ActorHooks for MyActor {}
25
26impl ActorBehavior for MyActor {
27    fn handle(&mut self, msg: MyActorMsg, ctx: &Context<Self>) {
28        match msg {
29            MyActorMsg::Add(a, b) => {
30                self.adder.send(AdderMsg::Add {
31                    a,
32                    b,
33                    respond: ctx.myself().chan(),
34                });
35            }
36
37            MyActorMsg::AddedResult(result) => {
38                println!("Result: {}", result);
39            }
40        }
41    }
42}
43
44struct Adder;
45
46impl Actor for Adder {
47    type Msg = AdderMsg;
48}
49
50impl ActorBehavior for Adder {
51    fn handle(&mut self, msg: AdderMsg, _: &Context<Self>) {
52        match msg {
53            AdderMsg::Add { a, b, respond } => {
54                respond.send(MyActorMsg::AddedResult(a + b));
55            }
56        }
57    }
58}
59
60impl ActorHooks for Adder {}
61
62fn run() {
63    let adder = Adder.start().chan();
64    let myactor = MyActor { adder }.start();
65
66    myactor.send(MyActorMsg::Add(1, 2));
67    myactor.send(MyActorMsg::Add(1, 5));
68}
69
70fn main() {
71    ActorSystem::run_to_completion(run);
72}
request_response/request_response.rs

request_response/
request_response.rs
