Struct LiveEngine 

pub struct LiveEngine { /* private fields */ }

Owns the reactive worker + the observer registration. Drop joins the worker and unregisters the observer (via the ObserverHandle).

Implementations

impl LiveEngine

pub fn new(db: Arc<Database>, schema: Arc<SchemaIr>) -> Arc<Self>

Builds the engine, registers the reactive observer on db’s notifier, and spawns the worker.

pub fn register( &self, collection: &str, filter: Value, options: QueryOptions, sink: Arc<dyn EmitSink>, ) -> (SubId, String)

Registers a live query. Returns its id and the synchronously computed initial snapshot envelope (so .value is populated without waiting for the first commit).

pub fn cancel(&self, sub: SubId)

Cancels a subscription; no further emissions for it.

Trait Implementations

impl Drop for LiveEngine

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.