Struct Consumer 

pub struct Consumer { /* private fields */ }

Queue consumer.

A process holding Consumer owns pops from the queue.

Implementations

impl Consumer

pub fn open() -> Result<Self>

Open an existing queue as consumer.

pub fn pop(&self) -> Option<[u8; 48]>

Pop one 48-byte value.

Returns None when the queue is empty.

pub fn capacity(&self) -> u64

Queue capacity in slots.

pub fn len(&self) -> u64

Current queue length in slots.

pub fn is_empty(&self) -> bool

Returns true when the queue is empty.

pub fn stats(&self) -> QueueStats

Current queue statistics.