Expand description
Async wrapper around crate::Queue using ove_queue_set_notify.
Same pattern as AsyncStream: own the wrapped primitive + an
AtomicWaker, register a C trampoline that wakes the waker, poll
try_recv with waker-recheck.
Lifetime: methods take &'static self because the C-side notify
retains a pointer to the internal AtomicWaker.
Structsยง
- Async
Queue - Async wrapper around an
ove::Queue.