Struct Group 

pub struct Group<K, T, E, 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> Group<K, T, E, RandomState>

pub fn new() -> Self

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

pub fn with_hasher(hasher: S) -> Self

impl<K, T, E, S> Group<K, T, E, 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<F, Fut>(&self, key: K, f: F) -> Arc<Outcome<T, E>>

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

Executes f 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, S> Clone for Group<K, T, E, S>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

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

fn default() -> Self

Returns the “default value” for a type.