Struct AsyncSpscRing 

pub struct AsyncSpscRing { /* private fields */ }

Wrapper providing .recv(timeout).await and .send(timeout).await.

Implementations

impl AsyncSpscRing

pub fn new(inner: Arc<BlockingSpscRing>) -> Self

Wrap an existing BlockingSpscRing. Both halves share the same underlying ring + wakers; this is just an async-shaped view of the same primitive.

pub fn recv(&self, timeout: Duration) -> AsyncRecv

Async pop with bounded wait. Returns a future that resolves when an item arrives, or BlockingError::Timeout after the caller-supplied duration.

pub fn send(&self, payload: Vec<u8>, timeout: Duration) -> AsyncSend

Async push with bounded wait.

pub fn inner(&self) -> &Arc<BlockingSpscRing>

Direct access to the underlying blocking ring.