Struct NotifyRead

pub struct NotifyRead<K, V> { /* private fields */ }

Implementations

impl<K: Eq + Hash + Clone, V: Clone> NotifyRead<K, V>

pub fn new() -> Self

pub fn notify(&self, key: &K, value: &V) -> usize

Asynchronously notifies waiters and return number of remaining pending registration

pub fn register_one(&self, key: &K) -> Registration<'_, K, V>

pub fn register_all(&self, keys: &[K]) -> Vec<Registration<'_, K, V>>

pub fn num_pending(&self) -> usize

impl<K: Eq + Hash + Clone + Unpin, V: Clone + Unpin> NotifyRead<K, V>

pub async fn read( &self, keys: &[K], fetch: impl FnOnce(&[K]) -> Vec<Option<V>>, ) -> Vec<V>

Trait Implementations

impl<K: Eq + Hash + Clone, V: Clone> Default for NotifyRead<K, V>

fn default() -> Self

Returns the “default value” for a type.