Struct MustJoinSingleFuture 

pub struct MustJoinSingleFuture<T>
where
    T: 'static,
{ /* private fields */ }

Spawns a single background processing task idempotently, possibly returning the return value of the previously executed background task This does not queue, just ensures that no more than a single copy of the task is running at a time, but allowing tasks to be retriggered

Implementations

impl<T> MustJoinSingleFuture<T>

where T: 'static,

pub fn new() -> Self

pub async fn check(&self) -> Result<Option<T>, ()>

Check the result and take it if there is one

pub async fn join(&self) -> Result<Option<T>, ()>

Wait for the result and take it

pub async fn single_spawn_local( &self, name: &str, future: impl Future<Output = T> + 'static, ) -> Result<(Option<T>, bool), ()>

impl<T> MustJoinSingleFuture<T>

where T: 'static + Send,

pub async fn single_spawn<F: Future<Output = T> + Send + 'static, C: FnOnce() -> F>( &self, name: &str, future_callback: C, ) -> Result<(Option<T>, bool), ()>

Trait Implementations

impl<T> Clone for MustJoinSingleFuture<T>

where T: 'static + Clone,

fn clone(&self) -> MustJoinSingleFuture<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> Debug for MustJoinSingleFuture<T>

where T: 'static + Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T> Default for MustJoinSingleFuture<T>

where T: 'static,

fn default() -> Self

Returns the “default value” for a type.