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, ) -> Self

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

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.