Struct DBusCallQueue 

pub struct DBusCallQueue { /* private fields */ }

A queue of asynchronous calls of which one is in flight at a time.

Implementations

impl DBusCallQueue

pub fn new( error_handler: impl Fn(DBusCallError) -> LocalBoxFuture<()> + 'static, ) -> Self

error_handler is awaited with the failure of a call nobody waits for (one queued with enqueue).

pub fn enqueue<F>(&self, cb: impl FnOnce() -> F + 'static)

where F: Future<Output = DBusResult> + 'static,

pub fn enqueue_async<F>( &self, cb: impl FnOnce() -> F + 'static, ) -> impl Future<Output = DBusResult> + 'static

where F: Future<Output = DBusResult> + 'static,

Queues a call and gives the future of its completion (EnqueueAsync).

pub fn enqueue_async_with_result<T, F>( &self, cb: impl FnOnce() -> F + 'static, ) -> impl Future<Output = DBusResult<T>> + 'static

where T: 'static, F: Future<Output = DBusResult<T>> + 'static,

Queues a call with a result and gives the future of the result (EnqueueAsync<T>).

pub fn fail_all(&self)

Empties the queue; the calls somebody waits for fail as canceled.

Trait Implementations

impl Clone for DBusCallQueue

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.