Struct ReactiveHandler 

pub struct ReactiveHandler { /* private fields */ }

Production reactive effect handler.

Implements ReactiveEffects using a SignalGraph for state management. This handler can be shared across components via Arc.

Supports query-bound signals where the signal’s value is derived from executing a query against journal facts. When facts change, bound queries are automatically re-evaluated.

Implementations

impl ReactiveHandler

pub fn new() -> Self

Create a new reactive handler with an empty signal graph.

pub fn with_graph(graph: Arc<SignalGraph>) -> Self

Create a handler with a shared signal graph.

This allows multiple handlers to share the same reactive state.

pub fn with_graph_and_registry( graph: Arc<SignalGraph>, registered_ids: Arc<RwLock<HashSet<SignalId>>>, ) -> Self

Create a handler with shared graph and registration tracking.

pub fn graph(&self) -> &Arc<SignalGraph>

Get a reference to the underlying signal graph.

pub async fn stats(&self) -> SignalGraphStats

Get statistics about the handler’s signal graph.

Trait Implementations

impl Clone for ReactiveHandler

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for ReactiveHandler

fn default() -> Self

Returns the “default value” for a type.

impl Drop for ReactiveHandler

fn drop(&mut self)

Executes the destructor for this type.

impl ReactiveEffects for ReactiveHandler

fn read<'life0, 'life1, 'async_trait, T>( &'life0 self, signal: &'life1 Signal<T>, ) -> Pin<Box<dyn Future<Output = Result<T, ReactiveError>> + Send + 'async_trait>>

where T: Clone + Send + Sync + 'static + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Read the current value of a signal.

fn emit<'life0, 'life1, 'async_trait, T>( &'life0 self, signal: &'life1 Signal<T>, value: T, ) -> Pin<Box<dyn Future<Output = Result<(), ReactiveError>> + Send + 'async_trait>>

where T: Clone + Send + Sync + 'static + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Emit a new value to a signal.

fn subscribe<T>( &self, signal: &Signal<T>, ) -> Result<SignalStream<T>, ReactiveError>

where T: Clone + Send + Sync + 'static,

Subscribe to signal changes.

fn register<'life0, 'life1, 'async_trait, T>( &'life0 self, signal: &'life1 Signal<T>, initial: T, ) -> Pin<Box<dyn Future<Output = Result<(), ReactiveError>> + Send + 'async_trait>>

where T: Clone + Send + Sync + 'static + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Register a signal with an initial value.

fn is_registered(&self, signal_id: &SignalId) -> bool

Check if a signal is registered.

fn register_query<'life0, 'life1, 'async_trait, Q>( &'life0 self, signal: &'life1 Signal<Q::Result>, query: Q, ) -> Pin<Box<dyn Future<Output = Result<(), ReactiveError>> + Send + 'async_trait>>

where Q: 'async_trait + Query, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Register a signal bound to a query.

fn query_dependencies(&self, signal_id: &SignalId) -> Option<Vec<FactPredicate>>

Get the fact predicates that a signal depends on.

fn invalidate_queries<'life0, 'life1, 'async_trait>( &'life0 self, changed: &'life1 FactPredicate, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Notify that facts matching a predicate have changed.