Struct SourceCache 

pub struct SourceCache<T, K> { /* private fields */ }

The source of a reactive keyed collection (SourceCache<TObject, TKey>): edits make change sets, which connect delivers to the operators.

Implementations

impl<T: Clone + 'static, K: Eq + Hash + Clone + 'static> SourceCache<T, K>

pub fn new(key_selector: impl Fn(&T) -> K + 'static) -> Self

An empty cache whose items are keyed by key_selector.

pub fn edit(&self, update: impl FnOnce(&mut dyn ISourceUpdater<T, K>))

Runs an edit (Edit(Action<ISourceUpdater>)).

pub fn suspend_count(&self) -> Rc<dyn IDisposable>

Holds back the notifications of count changes (SuspendCount).

pub fn suspend_notifications(&self) -> Rc<dyn IDisposable>

Holds back the notifications of changes (SuspendNotifications).

pub fn as_observable_cache_inner(&self) -> &ObservableCache<T, K>

The observable cache this source edits.

Trait Implementations

impl<T: Clone + 'static, K: Eq + Hash + Clone + 'static> CacheChangeSetSource for SourceCache<T, K>

type Item = T

The type of the items.

type Key = K

The type of the keys.

fn source_change_sets(&self) -> Rc<dyn IObservable<ChangeSet<T, K>>>

The change sets of the source: the sequence itself, or Connect() of a cache.

impl<T, K> Clone for SourceCache<T, K>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Clone + 'static, K: Eq + Hash + Clone + 'static> IConnectableCache<T, K> for SourceCache<T, K>

fn count_changed(&self) -> Rc<dyn IObservable<usize>>

The number of items, now and whenever it changes (CountChanged).

fn connect_with( &self, predicate: Option<Rc<dyn Fn(&T) -> bool>>, suppress_empty_change_sets: bool, ) -> Rc<dyn IObservable<ChangeSet<T, K>>>

The items as additions, then the changes, of the items that predicate accepts; empty change sets are left out unless suppress_empty_change_sets is false (Connect).

fn preview_with( &self, predicate: Option<Rc<dyn Fn(&T) -> bool>>, ) -> Rc<dyn IObservable<ChangeSet<T, K>>>

The changes before they are applied, while the items are as they were (Preview).

fn watch(&self, key: K) -> Rc<dyn IObservable<Change<T, K>>>

The changes of the item of key (Watch).

fn connect(&self) -> Rc<dyn IObservable<ChangeSet<T, K>>>

The items and their changes (Connect()).

fn connect_filtered( &self, predicate: impl Fn(&T) -> bool + 'static, ) -> Rc<dyn IObservable<ChangeSet<T, K>>>

where Self: Sized,

The items that predicate accepts and their changes (Connect(Func<TObject, bool>)).

fn preview(&self) -> Rc<dyn IObservable<ChangeSet<T, K>>>

The changes before they are applied (Preview()).

impl<T: Clone + 'static, K: Eq + Hash + Clone + 'static> IDisposable for SourceCache<T, K>

fn dispose(&self)

impl<T: Clone + 'static, K: Eq + Hash + Clone + 'static> IObservableCache<T, K> for SourceCache<T, K>

fn count(&self) -> usize

The number of items (Count).

fn items(&self) -> Vec<T>

The items (Items).

fn keys(&self) -> Vec<K>

The keys (Keys).

fn key_values(&self) -> Dictionary<K, T>

The keys and items (KeyValues).

fn lookup(&self, key: &K) -> Option<T>

The item of key (Lookup).

impl<T: Clone + 'static, K: Eq + Hash + Clone + 'static> ISourceCache<T, K> for SourceCache<T, K>

fn key_selector(&self) -> KeySelector<T, K>

The key selector of the items (KeySelector).

fn edit(&self, update: &mut dyn FnMut(&mut dyn ISourceUpdater<T, K>))

Runs an edit; its changes are delivered as one change set when it ends (Edit).