Struct TeaStore 

pub struct TeaStore<S, M> { /* private fields */ }

Writable store — dispatch actions; model snapshots arrive on subscription channels.

Implementations

impl<S, M> TeaStore<S, M>

where S: Send + Sync + Clone + 'static, M: Send + 'static,

pub fn send(&self, action: M) -> StoreTask

pub fn dispatch(&self, action: M)

pub fn try_state(&self) -> Result<S, TeaStoreError>

Request a point-in-time model snapshot from the reducer thread (blocks until reply).

pub fn state(&self) -> Result<S, TeaStoreError>

Same as Self::try_state — provided for call sites that expect infallible reads.

pub fn view_store(&self) -> TeaViewStore<S, M>

Read-only view handle — clone onto reader threads.

pub fn cancel(&self, id: EffectId)

pub fn try_subscribe_state( &self, ) -> Result<TeaStateSubscriber<S>, TeaStoreError>

where S: PartialEq,

pub fn subscribe_state(&self) -> Result<TeaStateSubscriber<S>, TeaStoreError>

where S: PartialEq,

Subscribe to model snapshots pushed after each reduce (no shared-state lock).

pub fn try_subscribe_changes( &self, ) -> Result<TeaChangeSubscriber<S>, TeaStoreError>

where S: FieldDiff + Hash + PartialEq,

pub fn subscribe_changes(&self) -> Result<TeaChangeSubscriber<S>, TeaStoreError>

where S: FieldDiff + Hash + PartialEq,

Field-level changes derived from pushed snapshots (no lock on live state).

pub fn scope<CS, CM, AK, SK>( &self, state_kp: SK, action_kp: AK, ) -> ScopedTeaStore<S, M, CS, CM, AK, SK>

where CS: Clone + PartialEq + Send + Sync + 'static, CM: Clone + Send + 'static, S: 'static, M: 'static, AK: Casepath<M, CM> + Clone + Send + Sync + 'static, SK: RefKpTrait<S, CS> + Clone,

Trait Implementations

impl<S, M> Clone for TeaStore<S, M>

where S: Send + 'static, M: Send + 'static,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.