Struct SubscribableRwLock 

pub struct SubscribableRwLock<T: Clone> { /* private fields */ }

A RwLock that can register subscribers to be notified upon state change.

Implementations

impl<T: Clone> SubscribableRwLock<T>

pub fn new(t: T) -> Self

create a new SubscribableRwLock

pub async fn modify<F>(&self, cb: F)

where F: FnOnce(&mut T),

subscribe to state changes. Receive the updated state upon state change

impl<T: Copy> SubscribableRwLock<T>

pub async fn copied(&self) -> T

Return a copy of the current value of T

Trait Implementations

impl<T: Debug + Clone> Debug for SubscribableRwLock<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T: Default + Clone> Default for SubscribableRwLock<T>

fn default() -> SubscribableRwLock<T>

Returns the “default value” for a type.

impl<T: Clone + Send + Sync> ReadView<T> for SubscribableRwLock<T>

fn subscribe<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = UnboundedReceiver<T>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

subscribe to state changes. Receive the updated state upon state change

fn cloned<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = T> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

async clone the internal state and return it

impl<T: Clone + Sync + Send + Debug> ThreadedReadView<T> for SubscribableRwLock<T>