moq_lite/message/group.rs
1use crate::coding::*;
2
3#[derive(Clone, Debug)]
4pub struct Group {
5 // The subscribe ID.
6 pub subscribe: u64,
7
8 // The group sequence number
9 pub sequence: u64,
10}
11
12impl Message for Group {
13 fn decode<R: bytes::Buf>(r: &mut R) -> Result<Self, DecodeError> {
14 Ok(Self {
15 subscribe: u64::decode(r)?,
16 sequence: u64::decode(r)?,
17 })
18 }
19
20 fn encode<W: bytes::BufMut>(&self, w: &mut W) {
21 self.subscribe.encode(w);
22 self.sequence.encode(w);
23 }
24}