Struct GenericStore 

pub struct GenericStore<PacketIdType: IsPacketId> { /* private fields */ }

A store that holds packets in insertion order and allows O(1) insert/remove by id.

Implementations

impl<PacketIdType: IsPacketId> GenericStore<PacketIdType>

pub fn new() -> Self

Create a new empty store.

pub fn add( &mut self, packet: GenericStorePacket<PacketIdType>, ) -> Result<(), MqttError>

Add a packet to the store. Returns true if inserted, false if a packet with same id already exists.

pub fn erase( &mut self, response: ResponsePacket, packet_id: PacketIdType, ) -> bool

Erase a packet by its response type and packet id. Returns true if removed, false otherwise.

pub fn erase_publish(&mut self, packet_id: PacketIdType) -> bool

Erase a publish packet by packet id only. Returns true if removed, false otherwise.

pub fn clear(&mut self)

Clear all stored packets.

pub fn for_each<F>(&mut self, func: F)

where F: FnMut(&GenericStorePacket<PacketIdType>) -> bool,

Iterate over packets in insertion order. The provided function returns true to keep the packet, or false to remove it.

pub fn get_stored(&self) -> Vec<GenericStorePacket<PacketIdType>>

Return a vector of all stored packets in insertion order.