Struct Queue 

pub struct Queue<T: Copy, const N: usize> { /* private fields */ }

Type-safe FIFO queue with compile-time capacity.

T must be a plain-old-data type (Copy) because items are transferred through the C API via raw byte copies. N is the queue capacity.

Implementations

impl<T: Copy, const N: usize> Queue<T, N>

pub fn new() -> Result<Self>

Create a queue via heap allocation (only in heap mode).

pub fn send(&self, item: &T, timeout_ms: u32) -> Result<()>

Send an item to the queue, blocking up to timeout_ms if the queue is full.

Errors

Returns Error::QueueFull or Error::Timeout if the item cannot be enqueued within timeout_ms.

pub fn receive(&self, timeout_ms: u32) -> Result<T>

Receive an item from the queue, blocking up to timeout_ms if the queue is empty.

Errors

Returns Error::Timeout if no item is available within timeout_ms.

pub fn send_from_isr(&self, item: &T) -> Result<()>

Send an item from an ISR context (non-blocking, returns immediately if full).

Errors

Returns Error::QueueFull if the queue has no space.

pub fn receive_from_isr(&self) -> Result<T>

Receive an item from an ISR context (non-blocking, returns immediately if empty).

Errors

Returns Error::Timeout if the queue is empty.

Trait Implementations

impl<T: Copy, const N: usize> Debug for Queue<T, N>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T: Copy, const N: usize> Drop for Queue<T, N>

fn drop(&mut self)

Executes the destructor for this type.

impl<T: Copy + Send, const N: usize> Send for Queue<T, N>

impl<T: Copy + Send, const N: usize> Sync for Queue<T, N>