use crate::coding::{DecodeError, EncodeError, VarInt}; use crate::coding::{AsyncRead, AsyncWrite}; /// Sent by the publisher to accept a Subscribe. #[derive(Clone, Debug)] pub struct SubscribeOk { // NOTE: No full track name because of this proposal: https://github.com/moq-wg/moq-transport/issues/209 // The ID for this track. pub id: VarInt, } impl SubscribeOk { pub async fn decode(r: &mut R) -> Result { let id = VarInt::decode(r).await?; Ok(Self { id }) } } impl SubscribeOk { pub async fn encode(&self, w: &mut W) -> Result<(), EncodeError> { self.id.encode(w).await?; Ok(()) } }