Struct Group 

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

Namespace for duplicate suppression.

For a given key, only the leader computes. Duplicate callers subscribe to the leader’s broadcast and receive the same Outcome.

Implementations

impl<K, T, E, F, Fut> Group<K, T, E, F, RandomState>

where F: Fn(K) -> Fut, Fut: Future<Output = Result<T, E>>,

pub fn new(op: F) -> Self

impl<K, T, E, F, S> Group<K, T, E, F, S>

pub fn with_hasher(op: F, hasher: S) -> Self

impl<K, T, E, F, S> Group<K, T, E, F, S>

where K: Eq + Hash, S: BuildHasher,

pub fn entry(&self, key: K) -> Entry<K, T, E, S>

Returns a leader for a new key, or a subscriber for an in-flight key.

pub async fn run<Fut>(&self, key: K) -> Arc<Outcome<T, E>>

where K: Clone, F: Fn(K) -> Fut, Fut: Future<Output = Result<T, E>>,

Executes this group’s operation once per key while an earlier call is in flight.

pub fn forget<Q>(&self, key: &Q)

where K: Borrow<Q>, Q: Hash + Eq + ?Sized,

Forgets a key so the next entry or run starts a fresh leader instead of joining the current call.

pub fn in_flight(&self) -> usize

Trait Implementations

impl<K, T, E, F, S> Clone for Group<K, T, E, F, S>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.