Struct RequestCoalescer 

pub struct RequestCoalescer<K, V>
where
    K: Hash + Eq + Clone,
    V: Clone + Send + 'static,
{ /* private fields */ }

Request coalescer for deduplicating concurrent requests.

Implementations

impl<K, V> RequestCoalescer<K, V>

where K: Hash + Eq + Clone + Send + Sync + 'static, V: Clone + Send + 'static,

pub fn new(config: CoalescerConfig) -> Self

Creates a new request coalescer.

pub fn with_defaults() -> Self

Creates a coalescer with default configuration.

pub async fn get_or_fetch<F, Fut>(&self, key: K, fetch: F) -> V

where F: FnOnce() -> Fut, Fut: Future<Output = V> + Send + 'static,

Gets a value, coalescing with any in-flight request for the same key.

pub fn stats(&self) -> CoalescerStats

Returns statistics.

pub async fn stats_async(&self) -> CoalescerStats

Returns statistics with in-flight count.

pub async fn clear(&self)

Clears all in-flight requests.

pub async fn cleanup_stale(&self)

Removes stale entries (older than max_wait).