Struct Group 

pub struct Group<T, E>
where
    T: ResultType + 'static,
    E: ResultError,
{ /* private fields */ }

Group represents a class of work and creates a space in which units of work can be executed with duplicate suppression.

Implementations

impl<T, E> Group<T, E>

where T: ResultType + 'static, E: ResultError + 'static,

pub fn new() -> Group<T, E>

Create a new Group to do work with.

pub async fn work( &self, key: &str, fut: impl TaskFuture<T, E> + 'static, ) -> (Result<T, SingleflightError<E>>, bool)

Execute and return the value for a given function, making sure that only one operation is in-flight at a given moment. If a duplicate call comes in, that caller will wait until the original call completes and return the same value. The second return value indicates whether the call is the owner.

On error, the owner will receive the original error returned from the function as a SingleflightError::InternalError, all waiters will receive a copy of the error message wrapped in a SingleflightError::WaiterInternalError. This is due to the fact that most error types don’t implement Clone (e.g. anyhow::Error) and thus we can’t clone the original error for all the waiters.

pub async fn work_dump_caller_info( &self, key: &str, fut: impl TaskFuture<T, E> + 'static, ) -> Result<T, SingleflightError<E>>

Like work but only returns the result, dumps the bool result value

Trait Implementations

impl<T, E> Debug for Group<T, E>

where T: ResultType + 'static + Debug, E: ResultError + Debug,

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

Formats the value using the given formatter.

impl<T, E> Default for Group<T, E>

where T: ResultType + 'static, E: ResultError + 'static,

fn default() -> Self

Returns the “default value” for a type.