Struct UnaryGroup 

pub struct UnaryGroup<K, T, S = RandomState> { /* private fields */ }

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

Implementations

impl<K, T, S> UnaryGroup<K, T, S>

where S: Default,

pub fn new() -> UnaryGroup<K, T, S>

Create a new Group to do work with.

impl<K, T, S> UnaryGroup<K, T, S>

where T: Clone + Send + Sync, K: Hash + Eq + Send + Sync, S: BuildHasher,

pub async fn work<Q, F>(&self, key: &Q, fut: F) -> T

where Q: Hash + Eq + ?Sized + Send + Sync + ToOwned<Owned = K>, F: Future<Output = T> + Send, K: Borrow<Q>,

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.

pub async fn work_no_retry<Q, F>(&self, key: &Q, fut: F) -> Option<T>

where Q: Hash + Eq + ?Sized + Send + Sync + ToOwned<Owned = K>, F: Future<Output = T> + Send, K: Borrow<Q>,

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.
• If the leader drops, the call will return None.

Trait Implementations

impl<K, T, S> Debug for UnaryGroup<K, T, S>

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

Formats the value using the given formatter.

impl<K, T, S> Default for UnaryGroup<K, T, S>

where S: Default,

fn default() -> Self

Returns the “default value” for a type.