Struct ReactiveMapCore 

pub struct ReactiveMapCore<K, V> {
    pub interceptors_any: Arc<Mutex<Vec<(u64, InterceptorAny<K, V>)>>>,
    pub interceptors_key: Arc<Mutex<HashMap<K, Vec<(u64, InterceptorKey<K, V>)>>>>,
    pub subscribers_any: Arc<Mutex<Vec<(u64, SubscriberAny<K, V>, SubscriptionMeta)>>>,
    pub subscribers_key: Arc<Mutex<HashMap<K, Vec<(u64, SubscriberKey<K, V>, SubscriptionMeta)>>>>,
    pub next_id: Arc<AtomicU64>,
    pub intercept_depth: Arc<AtomicUsize>,
    pub cache: Arc<Mutex<HashMap<K, V>>>,
}

Fields

interceptors_any: Arc<Mutex<Vec<(u64, InterceptorAny<K, V>)>>>

interceptors_key: Arc<Mutex<HashMap<K, Vec<(u64, InterceptorKey<K, V>)>>>>

subscribers_any: Arc<Mutex<Vec<(u64, SubscriberAny<K, V>, SubscriptionMeta)>>>

subscribers_key: Arc<Mutex<HashMap<K, Vec<(u64, SubscriberKey<K, V>, SubscriptionMeta)>>>>

next_id: Arc<AtomicU64>

intercept_depth: Arc<AtomicUsize>

cache: Arc<Mutex<HashMap<K, V>>>

Implementations

impl<K: ReactiveMapKey, V: ReactiveMapValue> ReactiveMapCore<K, V>

pub fn new() -> Self

pub fn subscribe_any<F>(&self, callback: F) -> SignalSubscription

where F: Fn(&MapChange<K, V>) + Send + Sync + 'static,

pub fn subscribe_key<F>(&self, key: K, callback: F) -> SignalSubscription

where F: Fn(&MapChange<K, V>) + Send + Sync + 'static,

pub fn intercept<F>(&self, path: Arc<str>, callback: F) -> InterceptDisposer

where F: Fn(MapChange<K, V>) -> Option<MapChange<K, V>> + Send + Sync + 'static,

pub fn intercept_key<F>(&self, key: K, callback: F) -> InterceptDisposer

where F: Fn(MapChange<K, V>) -> Option<MapChange<K, V>> + Send + Sync + 'static,

pub fn run_interceptors( &self, path: Arc<str>, change: MapChange<K, V>, ) -> Result<MapChange<K, V>, String>

pub fn notify(&self, change: &MapChange<K, V>)

Trait Implementations

impl<K, V> Clone for ReactiveMapCore<K, V>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<K: Debug, V: Debug> Debug for ReactiveMapCore<K, V>

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

Formats the value using the given formatter.

impl<K: ReactiveMapKey, V: ReactiveMapValue> Default for ReactiveMapCore<K, V>

fn default() -> Self

Returns the “default value” for a type.