moq_transfork/message/
setup.rs

1use super::{Extensions, Version, Versions};
2use crate::coding::*;
3
4/// Sent by the client to setup the session.
5#[derive(Debug, Clone)]
6pub struct ClientSetup {
7	/// The list of supported versions in preferred order.
8	pub versions: Versions,
9
10	/// Extensions.
11	pub extensions: Extensions,
12}
13
14impl Decode for ClientSetup {
15	/// Decode a client setup message.
16	fn decode<R: bytes::Buf>(r: &mut R) -> Result<Self, DecodeError> {
17		let versions = Versions::decode(r)?;
18		let extensions = Extensions::decode(r)?;
19
20		Ok(Self { versions, extensions })
21	}
22}
23
24impl Encode for ClientSetup {
25	/// Encode a server setup message.
26	fn encode<W: bytes::BufMut>(&self, w: &mut W) {
27		self.versions.encode(w);
28		self.extensions.encode(w);
29	}
30}
31
32/// Sent by the server in response to a client setup.
33#[derive(Debug, Clone)]
34pub struct ServerSetup {
35	/// The list of supported versions in preferred order.
36	pub version: Version,
37
38	/// Supported extenisions.
39	pub extensions: Extensions,
40}
41
42impl Decode for ServerSetup {
43	/// Decode the server setup.
44	fn decode<R: bytes::Buf>(r: &mut R) -> Result<Self, DecodeError> {
45		let version = Version::decode(r)?;
46		let extensions = Extensions::decode(r)?;
47
48		Ok(Self { version, extensions })
49	}
50}
51
52impl Encode for ServerSetup {
53	fn encode<W: bytes::BufMut>(&self, w: &mut W) {
54		self.version.encode(w);
55		self.extensions.encode(w);
56	}
57}
moq_transfork/message/setup.rs

moq_transfork/message/
setup.rs
