Struct SingleFlight

pub struct SingleFlight<K, 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<K, T> SingleFlight<K, T>

where K: Hash + Eq + Clone,

pub fn new() -> Self

Create a new BroadcastOnce to do work with.

pub fn work<F, Fut>(&self, key: K, 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<K: Debug, T: Debug> Debug for SingleFlight<K, T>

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

Formats the value using the given formatter.

impl<K, T> Default for SingleFlight<K, T>

fn default() -> Self

Returns the “default value” for a type.