interthread 3.1.0

Auto implementation of the Actor Model
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
56
57
58
59
60
61
62
63
64
65
66
67



// STD

#[test]
fn interact_simple(){
    /*
        Usually we need  "inter_send" and "inter_recv" if we 
        spawn a thread inside the method, but this is not 
        the reason for this test
    */

    pub struct Actor;

    #[interthread::actor(debut,interact)] 
    impl Actor {

        pub fn new() -> Self { Self{} } 
        
        pub fn needs_sender(&self, (a,b,..):(u8,u8,u8), inter_send: oneshot::Sender<String>){
            let _ = inter_send.send(format!("{a}-{b}"));
        }

        pub fn needs_receiver(&self, [ref a @ .., b]: [u8;4],inter_recv: oneshot::Receiver<oneshot::Sender<String>>){
            let sender = inter_recv.recv().unwrap();
            let _ = sender.send(format!("{a:?}-{b}"));
        }

        pub fn needs_name_and_state(&mut self, mut inter_name: String, inter_state: u8 ) -> String {
            inter_name += &format!("-{inter_state}");
            inter_name
        }
    }
    // impl a custom getter
    impl ActorLive {
        fn inter_get_state(&self)-> u8 { 121 }
    }

    let mut act = ActorLive::new();
   

    assert_eq!(
        act.needs_sender((1,2,3u8)).recv().unwrap(), 
        "1-2".to_string()
    );

    // call the method 
    let sender = act.needs_receiver([1,2,3,4u8]);
    let (send,recv) = oneshot::channel::<String>();
    // send the value( channel in this case )
    let _ = sender.send(send);

    assert_eq!(
        recv.recv().unwrap(),
        "[1, 2, 3]-4".to_string()
    );

    act.inter_set_name("Cloud");
    assert_eq!(
        act.needs_name_and_state(),
        "Cloud-121".to_string()
    )
}