Struct PacketIdManager

pub struct PacketIdManager<T>
where
    T: IsPacketId,
{ /* private fields */ }

Implementations

impl<T> PacketIdManager<T>

where T: IsPacketId,

pub fn new() -> Self

Create a new packet ID manager with valid IDs in range [1, T::max_value()]

pub fn acquire_unique_id(&mut self) -> Result<T, MqttError>

Acquire a new unique packet ID. Returns Ok(T) if successful, Err(MqttError) if no IDs are available.

pub fn register_id(&mut self, packet_id: T) -> Result<(), MqttError>

Register a packet ID externally acquired or reused. Returns Ok(()) if successful, Err(MqttError) if the ID is already in use.

pub fn is_used_id(&self, packet_id: T) -> bool

Check whether a packet ID is in use.

pub fn release_id(&mut self, packet_id: T)

Release a previously acquired or registered packet ID.

pub fn clear(&mut self)

Clear all state: all packet IDs become available again.