Struct QueueSender

pub struct QueueSender<S, C> { /* private fields */ }

An async-supported sending-half of a Queue. This is to support systems that want to asynchronously send items to a receiver, under the assumption that the receiver sends completions to indicate that a request has been finished, and that the send ID can be reused.

Thus, this queue interally allocates, sends, and reuses IDs for requests.

Implementations

impl<S: Copy, C: Copy> QueueSender<S, C>

pub fn new(queue: Queue<S, C>) -> Self

Build a new QueueSender from a Queue.

pub fn submit_no_wait(&self, item: S, flags: SubmissionFlags)

Submit a request and don’t wait for a response. WARNING: This will burn a request ID, preventing it from ever being reused. This function is mostly useful for signalling an “end of communication” event across the queue. If you want to submit and not immediately await, you probably should create a task for your async block instead.

pub async fn submit_and_wait(&self, item: S) -> Result<C, QueueError>

Submit an item and await a completion.