Struct QueryWatcher 

pub struct QueryWatcher { /* private fields */ }

Watches a query and emits updates when results change

Implementations

impl QueryWatcher

pub fn new( collection: impl Into<String>, listener: ChangeListener, state: Arc<ReactiveQueryState>, initial_results: Vec<Document>, ) -> Self

Create a new query watcher

Arguments

• collection - Collection to watch
• listener - Change listener for the collection
• state - Reactive query state
• initial_results - Initial query results to populate the state

pub async fn next(&mut self) -> Option<QueryUpdate>

Get the next query update Returns None when the watcher is closed

pub fn collection(&self) -> &str

Get the collection name being watched

pub fn try_next(&mut self) -> Option<QueryUpdate>

Try to receive an update without blocking