Struct ContinuousQuery 

pub struct ContinuousQuery { /* private fields */ }

Implementations

impl ContinuousQuery

pub fn new( query: Arc<Query>, match_path: Arc<MatchPath>, expression_evaluator: Arc<ExpressionEvaluator>, element_index: Arc<dyn ElementIndex>, path_solver: Arc<MatchPathSolver>, part_evaluator: Arc<QueryPartEvaluator>, future_queue: Arc<dyn FutureQueue>, source_pipelines: SourceMiddlewarePipelineCollection, session_control: Arc<dyn SessionControl>, ) -> Self

pub async fn process_source_change( &self, change: SourceChange, ) -> Result<Vec<QueryPartEvaluationContext>, EvaluationError>

pub async fn process_due_futures( &self, ) -> Result<Option<DueFutureResult>, EvaluationError>

Atomically pop a due future from the queue and process it within a single session.

Returns Ok(None) when the queue is empty (stale peek). Returns Ok(Some(DueFutureResult)) with results and the original source_id.

Pop happens inside the session → atomic with all downstream index writes. If a crash occurs before commit, the pop rolls back and the item stays in the queue.

pub fn future_queue(&self) -> Arc<dyn FutureQueue>

Expose the ContinuousQuery’s future queue for external polling.

pub async fn set_future_consumer(&self, consumer: Arc<dyn FutureQueueConsumer>)

pub async fn terminate_future_consumer(&self)

pub fn get_query(&self) -> Arc<Query>

Trait Implementations

impl Debug for ContinuousQuery

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for ContinuousQuery

fn drop(&mut self)

Executes the destructor for this type.