mpstthree 0.1.17

A library implementing Multiparty Session Types for 2 or more participants
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
68
69
70
71
72
73
74
75
76
77
78
79
80

use std::thread::spawn;

use crossbeam_channel::{bounded, Receiver};

type S0 = Receiver<
    Receiver<
        Receiver<
            Receiver<Receiver<Receiver<Receiver<Receiver<Receiver<Receiver<Receiver<()>>>>>>>>,
        >,
    >,
>;
type S1 = Receiver<
    Receiver<Receiver<Receiver<Receiver<Receiver<Receiver<Receiver<Receiver<Receiver<()>>>>>>>>>,
>;
type S2 =
    Receiver<Receiver<Receiver<Receiver<Receiver<Receiver<Receiver<Receiver<Receiver<()>>>>>>>>>;
type S3 = Receiver<Receiver<Receiver<Receiver<Receiver<Receiver<Receiver<Receiver<()>>>>>>>>;
type S4 = Receiver<Receiver<Receiver<Receiver<Receiver<Receiver<Receiver<()>>>>>>>;
type S5 = Receiver<Receiver<Receiver<Receiver<Receiver<Receiver<()>>>>>>;
type S6 = Receiver<Receiver<Receiver<Receiver<Receiver<()>>>>>;
type S7 = Receiver<Receiver<Receiver<Receiver<()>>>>;
type S8 = Receiver<Receiver<Receiver<()>>>;
type S9 = Receiver<Receiver<()>>;
type S10 = Receiver<()>;
type S11 = ();

fn main() {
    let main = spawn(move || {
        let (sender_s_0, receiver_s_0) = bounded::<S0>(1);
        let (sender_s_1, receiver_s_1) = bounded::<S1>(1);
        let (sender_s_2, receiver_s_2) = bounded::<S2>(1);
        let (sender_s_3, receiver_s_3) = bounded::<S3>(1);
        let (sender_s_4, receiver_s_4) = bounded::<S4>(1);
        let (sender_s_5, receiver_s_5) = bounded::<S5>(1);
        let (sender_s_6, receiver_s_6) = bounded::<S6>(1);
        let (sender_s_7, receiver_s_7) = bounded::<S7>(1);
        let (sender_s_8, receiver_s_8) = bounded::<S8>(1);
        let (sender_s_9, receiver_s_9) = bounded::<S9>(1);
        let (sender_s_10, receiver_s_10) = bounded::<S10>(1);
        let (sender_s_11, receiver_s_11) = bounded::<S11>(1);

        sender_s_0.send(receiver_s_1).unwrap();
        let receiver_s_1_bis = receiver_s_0.recv().unwrap();

        sender_s_1.send(receiver_s_2).unwrap();
        let receiver_s_2_bis = receiver_s_1_bis.recv().unwrap();

        sender_s_2.send(receiver_s_3).unwrap();
        let receiver_s_3_bis = receiver_s_2_bis.recv().unwrap();

        sender_s_3.send(receiver_s_4).unwrap();
        let receiver_s_4_bis = receiver_s_3_bis.recv().unwrap();

        sender_s_4.send(receiver_s_5).unwrap();
        let receiver_s_5_bis = receiver_s_4_bis.recv().unwrap();

        sender_s_5.send(receiver_s_6).unwrap();
        let receiver_s_6_bis = receiver_s_5_bis.recv().unwrap();

        sender_s_6.send(receiver_s_7).unwrap();
        let receiver_s_7_bis = receiver_s_6_bis.recv().unwrap();

        sender_s_7.send(receiver_s_8).unwrap();
        let receiver_s_8_bis = receiver_s_7_bis.recv().unwrap();

        sender_s_8.send(receiver_s_9).unwrap();
        let receiver_s_9_bis = receiver_s_8_bis.recv().unwrap();

        sender_s_9.send(receiver_s_10).unwrap();
        let receiver_s_10_bis = receiver_s_9_bis.recv().unwrap();

        sender_s_10.send(receiver_s_11).unwrap();
        let receiver_s_11_bis = receiver_s_10_bis.recv().unwrap();

        sender_s_11.send(()).unwrap();
        receiver_s_11_bis.recv().unwrap();
    });

    main.join().unwrap();
}