Struct CallbackQueueReceiver

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

A receiver-side async-enabled queue abstraction.

Implementations

impl<S: Copy + Send + Sync, C: Copy + Send + Sync> CallbackQueueReceiver<S, C>

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

Create a new CallbackQueueReceiver from a Queue.

pub async fn handle<F, Fut>(&self, f: F) -> Result<(), Error>

where F: FnOnce(u32, S) -> Fut, Fut: Future<Output = C>,

Handle a request in a closure that returns a completion.

pub async fn receive(&self) -> Result<(u32, S), Error>

Receive a request without immediately returning a completion.

pub async fn complete(&self, id: u32, reply: C) -> Result<(), Error>

Send a completion back to the sender.