Struct WatcherRegistry 

pub struct WatcherRegistry { /* private fields */ }

Registry of state watchers, evaluated after each mutation cycle.

Implementations

impl WatcherRegistry

pub fn new() -> WatcherRegistry

Create an empty registry.

pub fn register(&mut self, watcher: Watcher)

Register a watcher.

pub fn observed_keys(&self) -> &HashSet<String>

The set of state keys observed by at least one watcher.

Used by the processor to scope State::snapshot_values() so only relevant keys are captured before mutations.

pub fn describe(&self) -> Vec<WatcherContract>

Return serializable contract metadata for all watchers.

pub fn evaluate( &self, diffs: &[(String, Value, Value)], state: &State, writer: &Arc<dyn SessionWriter>, ) -> (Vec<Pin<Box<dyn Future<Output = ()> + Send>>>, Vec<Pin<Box<dyn Future<Output = ()> + Send>>>)

Evaluate all watchers against the given state diffs.

diffs contains (key, old_value, new_value) tuples produced by State::diff_values(). For each diff entry, every watcher whose key matches and whose predicate fires will have its action invoked.

Returns (blocking_futures, concurrent_futures).

pub fn evaluate_mutations( &self, mutations: &[StateMutation], state: &State, writer: &Arc<dyn SessionWriter>, ) -> (Vec<Pin<Box<dyn Future<Output = ()> + Send>>>, Vec<Pin<Box<dyn Future<Output = ()> + Send>>>)

Evaluate watchers from a batch of recorded state mutations.

Multiple mutations for the same key are collapsed into the same net (old, new) diff shape used by Self::evaluate, preserving watcher behavior while avoiding a pre-turn state snapshot.

Trait Implementations

impl Default for WatcherRegistry

fn default() -> WatcherRegistry

Returns the “default value” for a type.