moq_lite/lite/
group.rs

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

moq_lite/lite/group.rs

moq_lite/lite/
group.rs