rtps-rs 0.1.2

Real Time Publish Subscribe protocol
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
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107

use speedy::{Readable, Writable};

#[derive(Debug, PartialEq, Eq, Readable, Writable)]
pub struct SubmessageKind {
    value: u8,
}

impl SubmessageKind {
    pub const PAD: SubmessageKind = SubmessageKind { value: 0x01 };
    pub const ACKNACK: SubmessageKind = SubmessageKind { value: 0x06 };
    pub const HEARTBEAT: SubmessageKind = SubmessageKind { value: 0x07 };
    pub const GAP: SubmessageKind = SubmessageKind { value: 0x08 };
    pub const INFO_TS: SubmessageKind = SubmessageKind { value: 0x09 };
    pub const INFO_SRC: SubmessageKind = SubmessageKind { value: 0x0c };
    pub const INFO_REPLAY_IP4: SubmessageKind = SubmessageKind { value: 0x0d };
    pub const INFO_DST: SubmessageKind = SubmessageKind { value: 0x0e };
    pub const INFO_REPLAY: SubmessageKind = SubmessageKind { value: 0x0f };
    pub const NACK_FRAG: SubmessageKind = SubmessageKind { value: 0x12 };
    pub const HEARTBEAT_FRAG: SubmessageKind = SubmessageKind { value: 0x13 };
    pub const DATA: SubmessageKind = SubmessageKind { value: 0x15 };
    pub const DATA_FRAG: SubmessageKind = SubmessageKind { value: 0x16 };
}

#[cfg(test)]
mod tests {
    use super::*;

    serialization_test!( type = SubmessageKind,
    {
        submessage_kind_pad,
        SubmessageKind::PAD,
        le = [0x01],
        be = [0x01]
    },
    {
        submessage_kind_acknack,
        SubmessageKind::ACKNACK,
        le = [0x06],
        be = [0x06]
    },
    {
        submessage_kind_heartbeat,
        SubmessageKind::HEARTBEAT,
        le = [0x07],
        be = [0x07]
    },
    {
        submessage_kind_gap,
        SubmessageKind::GAP,
        le = [0x08],
        be = [0x08]
    },
    {
        submessage_kind_info_ts,
        SubmessageKind::INFO_TS,
        le = [0x09],
        be = [0x09]
    },
    {
        submessage_kind_info_src,
        SubmessageKind::INFO_SRC,
        le = [0x0c],
        be = [0x0c]
    },
    {
        submessage_kind_info_replay_ip4,
        SubmessageKind::INFO_REPLAY_IP4,
        le = [0x0d],
        be = [0x0d]
    },
    {
        submessage_kind_info_dst,
        SubmessageKind::INFO_DST,
        le = [0x0e],
        be = [0x0e]
    },
    {
        submessage_kind_info_replay,
        SubmessageKind::INFO_REPLAY,
        le = [0x0f],
        be = [0x0f]
    },
    {
        submessage_kind_nack_frag,
        SubmessageKind::NACK_FRAG,
        le = [0x12],
        be = [0x12]
    },
    {
        submessage_kind_heartbeat_frag,
        SubmessageKind::HEARTBEAT_FRAG,
        le = [0x13],
        be = [0x13]
    },
    {
        submessage_kind_data,
        SubmessageKind::DATA,
        le = [0x15],
        be = [0x15]
    },
    {
        submessage_kind_data_frag,
        SubmessageKind::DATA_FRAG,
        le = [0x16],
        be = [0x16]
    });
}