Skip to main content

Module queue

Module queue 

Source
Expand description

Bounded frame queue with guaranteed delivery.

Queue is the counterpart to crate::RingBuffer: instead of silently dropping the oldest frames when the byte budget is exceeded, it rejects new pushes with crate::Error::ChannelFull. This makes it suitable for channels where every frame must be delivered (e.g. control messages, transaction logs).

§Wire format (drain_all)

The wire format is identical to crate::RingBuffer::drain_all:

[u32 LE frame_count]
[u32 LE len_1][bytes_1]
[u32 LE len_2][bytes_2]
...

Structs§

Queue
Thread-safe, bounded FIFO queue with backpressure.