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<&NotifyRead<K, V>, K, V>

pub fn register_one_owned(self: &Arc<Self>, key: &K) -> OwnedRegistration<K, V>

Like NotifyRead::register_one, but the returned registration holds the registry by Arc instead of borrowing it, so it can be stored in long-lived structures.

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

Register a waiter whose receiver blocks the OS thread (see BlockingRegistration::wait). Must not be awaited from async code.

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

pub fn num_pending(&self) -> usize

pub fn read_one_blocking( &self, task_name: &'static str, key: &K, fetch: impl FnOnce(&K) -> Option<V>, ) -> V

Blocking version of Self::read for a single key: returns fetch(key) if the value is already available, and otherwise blocks the calling OS thread until the key is notified.

Must not be called from an async context. Under msim it may only be called from a blocking-pool thread (e.g. inside spawn_blocking), where the wait yields the thread’s quantum between readiness checks.

impl<K: Eq + Hash + Clone + Unpin + Debug + Send + Sync + 'static, V: Clone + Unpin> NotifyRead<K, V>

pub async fn read( &self, task_name: &'static str, 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.