Struct SubscribeIdAllocator 

pub struct SubscribeIdAllocator {
    next_id: u64,
    max_id: u64,
}

Allocates and validates subscribe IDs per the MoQT draft-08 spec.

Draft-07 has no client/server parity rule for subscribe IDs (unlike the draft-14 request ID allocator). The subscriber allocates IDs monotonically starting at 0; FETCH and SUBSCRIBE share the same namespace since each carries a subscribe_id field.

Fields

next_id: u64

max_id: u64

Implementations

impl SubscribeIdAllocator

pub fn new() -> Self

Create a new allocator starting at subscribe_id 0 with max_id = 0 (blocked until the peer sends MAX_SUBSCRIBE_ID).

pub fn allocate(&mut self) -> Result<VarInt, SubscribeIdError>

Allocate the next subscribe ID.

pub fn update_max(&mut self, new_max: u64) -> Result<(), SubscribeIdError>

Update the maximum allowed subscribe ID (can only increase).

pub fn validate_peer_id(&self, id: u64) -> Result<(), SubscribeIdError>

Validate a subscribe ID received from the peer.

pub fn is_blocked(&self) -> bool

Check if we are blocked (max_id is 0 or next_id >= max_id).

pub fn max_id(&self) -> u64

Get the current maximum subscribe ID.

Trait Implementations

impl Default for SubscribeIdAllocator

fn default() -> Self

Returns the “default value” for a type.