Struct DataConnectQueryRuntime 

pub struct DataConnectQueryRuntime { /* private fields */ }

Owns the cached QueryManager for a service, allowing callers to explicitly control when observer state is created or discarded.

Implementations

impl DataConnectQueryRuntime

pub fn service(&self) -> &Arc<DataConnectService>

Returns the service associated with this runtime.

pub async fn execute_query( &self, query_ref: &QueryRef, ) -> DataConnectResult<QueryResult>

Executes the provided query reference using this runtime’s cached manager.

pub async fn subscribe( &self, query_ref: QueryRef, handlers: QuerySubscriptionHandlers, initial_cache: Option<SerializedQuerySnapshot>, ) -> DataConnectResult<QuerySubscriptionHandle>

Subscribes to a query using this runtime’s cached manager.

pub fn close(self)

Releases the cached manager immediately. Dropping the runtime has the same effect.

Trait Implementations

impl Drop for DataConnectQueryRuntime

fn drop(&mut self)

Executes the destructor for this type.