Struct singleflight_async::SingleFlight

pub struct SingleFlight<T> { /* private fields */ }

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

Implementations

impl<T> SingleFlight<T>

pub fn new() -> Self

Create a new BroadcastOnce to do work with.

pub fn work_with_owned_key<F, Fut>(
    &self,
    key: Cow<'static, str>,
    func: F
) -> impl Future<Output = T> where
    F: FnOnce() -> Fut,
    Fut: Future<Output = T>,
    T: Clone, 

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 key is a Owned key. The performance will be slightly better than work.

pub fn work<F, Fut>(&self, key: &str, func: F) -> impl Future<Output = T> where
    F: FnOnce() -> Fut,
    Fut: Future<Output = T>,
    T: Clone, 

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.

Trait Implementations

impl<T: Debug> Debug for SingleFlight<T>

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

Formats the value using the given formatter.

impl<T> Default for SingleFlight<T>

fn default() -> Self

Returns the “default value” for a type.