Struct LiveQuery 

pub struct LiveQuery<T, E> { /* private fields */ }

A subscription’s results and lifetime; dropping it ends future runs. Its results fail with E, the query closure’s own error type.

Implementations

impl<T: Send + 'static, E: From<DbError> + CarriesBug + Send + 'static> LiveQuery<T, E>

pub async fn next(&mut self) -> Option<Result<T, E>>

where T: Clone + PartialEq,

The first result at once; then only changed results. Errors remain results and don’t end the query, except the one reporting that the store closed, the handle failed or a run’s error carries a bug, as a panic’s does: after it, None.

pub fn runs(&self) -> LiveQueryRuns

How often this query has run so far.

pub fn is_marked_for_rerun(&self) -> bool

Whether a commit since this idle query’s last result changes what it reads, so asking for its next result runs it again, with no waiting.

pub fn process<P, U>(self, process: P) -> LiveQuery<U, E>

where T: Clone + PartialEq, P: Fn(T) -> Result<U, E> + Send + Sync + 'static, U: Send + 'static,

Process each value on a worker after its connection has been released. Equality is tested on the processed value.