Struct ReactiveQueryState 

pub struct ReactiveQueryState { /* private fields */ }

Tracks the current state of a reactive query

Implementations

impl ReactiveQueryState

pub fn new<F>(filter: F) -> Self

where F: Fn(&Document) -> bool + Send + Sync + 'static,

pub fn matches(&self, doc: &Document) -> bool

Check if a document matches the query filter

pub async fn add_if_matches(&self, doc: Document) -> Option<QueryUpdate>

Add a document to results if it matches

pub async fn remove(&self, id: &str) -> Option<QueryUpdate>

Remove a document from results

pub async fn update(&self, id: &str, new_doc: Document) -> Option<QueryUpdate>

Update a document, checking if it should be added/removed/modified

pub async fn get_results(&self) -> Vec<Document>

Get current results as a Vec

pub async fn count(&self) -> usize

Get count of current results