Struct AsyncSender 

pub struct AsyncSender<T>(/* private fields */);

The asynchronous sender endpoint for a VMO-backed FIFO queue.

Implementations

impl<T: FromBytes + IntoBytes + KnownLayout + Copy> AsyncSender<T>

pub fn new( vmo: Vmo, alignment: usize, queue_capacity: u32, ) -> Result<Self, Status>

Creates a new AsyncSender.

• vmo - The shared VMO used for queue messages and payload buffers.
• alignment - The byte alignment boundaries required for allocations. Modulo padding is applied so that all payload offsets begin aligned to this size. Must be a power of two.
• queue_capacity - The maximum number of queue slots.

pub fn capacity(&self) -> u32

Returns the maximum number of items the queue can hold.

pub fn is_full(&self) -> bool

pub fn vmo(&self) -> &Vmo

pub async fn push(&mut self, msg: T) -> Result<u64, Status>

Pushes a standalone message onto the queue, yielding to the executor if the queue is full.

pub async fn reserve_payload( &mut self, size: usize, ) -> Result<AsyncPayloadBuffer<'_, T>, Status>

Reserves a payload buffer in the VMO. Yields to the executor if there is insufficient payload capacity available. Returns an AsyncPayloadBuffer that commits on success or rolls back on drop.