Struct AsyncQueue 

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

Async wrapper around an ove::Queue.

Implementations

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

pub const fn new(inner: Queue<T, N>) -> Self

Wrap a queue for async use. See Self::arm for the lifetime constraint.

pub fn arm(&'static self) -> Result<()>

Register the C-side notify callback. Must be called exactly once after the wrapper reaches its final ’static location.

pub async fn recv(&'static self) -> Result<T>

Async receive — yields control until an item is available, then returns it.

pub fn inner(&self) -> &Queue<T, N>

Borrow the underlying Queue for synchronous operations (try_send, etc.).

Trait Implementations

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

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