rmemstore_messages/
protosocket_adapter.rs

1use crate::{Response, Rpc};
2
3impl protosocket_rpc::Message for Rpc {
4    fn message_id(&self) -> u64 {
5        self.id
6    }
7
8    fn control_code(&self) -> protosocket_rpc::ProtosocketControlCode {
9        protosocket_rpc::ProtosocketControlCode::from_u8(self.code as u8)
10    }
11
12    fn set_message_id(&mut self, message_id: u64) {
13        self.id = message_id;
14    }
15
16    fn cancelled(message_id: u64) -> Self {
17        Self {
18            id: message_id,
19            code: protosocket_rpc::ProtosocketControlCode::Cancel.as_u8() as u32,
20            command: None,
21        }
22    }
23
24    fn ended(message_id: u64) -> Self {
25        Self {
26            id: message_id,
27            code: protosocket_rpc::ProtosocketControlCode::End.as_u8() as u32,
28            command: None,
29        }
30    }
31}
32
33impl protosocket_rpc::Message for Response {
34    fn message_id(&self) -> u64 {
35        self.id
36    }
37
38    fn control_code(&self) -> protosocket_rpc::ProtosocketControlCode {
39        protosocket_rpc::ProtosocketControlCode::from_u8(self.code as u8)
40    }
41
42    fn set_message_id(&mut self, message_id: u64) {
43        self.id = message_id;
44    }
45
46    fn cancelled(message_id: u64) -> Self {
47        Self {
48            id: message_id,
49            code: protosocket_rpc::ProtosocketControlCode::Cancel.as_u8() as u32,
50            kind: None,
51        }
52    }
53
54    fn ended(message_id: u64) -> Self {
55        Self {
56            id: message_id,
57            code: protosocket_rpc::ProtosocketControlCode::End.as_u8() as u32,
58            kind: None,
59        }
60    }
61}
rmemstore_messages/protosocket_adapter.rs

rmemstore_messages/
protosocket_adapter.rs
