kernel 1.1.0

Abstract Reactive Streams
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


#[derive(PartialEq, Debug,Clone)]
pub struct Pub {
    pub from: usize,
    pub to: usize,
    pub task_id: usize,
    pub name: String,
    pub cap: usize,
}

#[derive(PartialEq, Debug,Clone)]
pub struct Sub {
    pub from: usize,
    pub to: usize,
    pub task_id: usize,
    pub pub_id: usize,
}

#[derive(PartialEq, Debug,Clone)]
pub struct Spawn {
    pub from: usize,
    pub to: usize,
    pub txt: String,
}

#[derive(PartialEq, Debug,Clone)]
pub struct AckSub {
    pub from: usize,
    pub to: usize,
    pub task_id: usize,
    pub result_id: usize, //    pub s: Subscriber<Message>,
}

#[derive(PartialEq, Debug,Clone)]
pub struct AckPub {
    pub from: usize,
    pub to: usize,
    pub task_id: usize,
    pub result_id: usize,
}

#[derive(PartialEq, Debug,Clone)]
pub struct AckSpawn {
    pub from: usize,
    pub to: usize,
    pub task_id: usize,
}

#[derive(PartialEq, Debug,Clone)]
pub enum Message {
    Pub(Pub),
    Sub(Sub),
    Print(String),
    Spawn(Spawn),
    AckSub(AckSub),
    AckPub(AckPub),
    AckSpawn(AckSpawn),
    Exec(usize, String),
    Select(String, u16),
    QoS(u8, u8, u8),
    Halt,
    Nop,
}

impl Message {
    pub fn from_u8(b: &[u8]) -> Self {
        //
        Message::Nop
    }
}