Struct ReactiveQuery 

pub struct ReactiveQuery<R, F> { /* private fields */ }

A live query over a document: re-evaluates query when the document changes and yields the new result only when it differs from the last emitted one.

Implementations

impl<R, F> ReactiveQuery<R, F>

where R: Clone + PartialEq, F: Fn(&CrdtDoc) -> R,

pub fn new(doc: &CrdtDoc, query: F) -> Self

Build a reactive query over doc, evaluating query once for the initial value.

pub fn poll(&mut self, doc: &CrdtDoc) -> Option<R>

Poll for an update. Returns Some(new_result) if the document changed and the query result changed since the last emission (the pushed delta); otherwise None.

pub fn current(&self) -> &R

The last evaluated result.