Struct QueryRegistry 

pub struct QueryRegistry { /* private fields */ }

Registry for tracking re-query observables and routing table changes. Supports batching of changes to avoid redundant re-queries during rapid updates.

Implementations

impl QueryRegistry

pub fn new() -> Self

Creates a new query registry.

pub fn set_self_ref(&mut self, self_ref: Rc<RefCell<QueryRegistry>>)

Sets the self reference for scheduling flush callbacks. Must be called after wrapping in Rc<RefCell<>>.

pub fn register( &mut self, query: Rc<RefCell<ReQueryObservable>>, table_id: TableId, )

Registers a query with its dependent table.

pub fn on_table_change(&mut self, table_id: TableId, changed_ids: &HashSet<u64>)

Handles table changes by batching and scheduling a flush. Multiple rapid changes are coalesced into a single re-query.

pub fn flush(&self)

Forces an immediate flush of all pending changes. Useful for testing or when you need synchronous behcynos.

pub fn query_count(&self) -> usize

Returns the number of registered queries.

pub fn has_pending_changes(&self) -> bool

Returns whether there are pending changes waiting to be flushed.

Trait Implementations

impl Default for QueryRegistry

fn default() -> Self

Returns the “default value” for a type.