Struct EntityLiveQuery 

pub struct EntityLiveQuery(/* private fields */);

A local subscription that handles both reactor subscription and remote cleanup This is a type-erased version that can be used in the TContext trait

Whether the query keeps its node alive is a construction-time choice: EntityLiveQuery::new holds the node strongly, EntityLiveQuery::new_weak_node does not.

Implementations

impl EntityLiveQuery

pub fn new<SE, PA>( node: &Node<SE, PA>, collection_id: CollectionId, args: MatchArgs, cdata: PA::ContextData, ) -> Result<Self, RetrievalError>

where SE: StorageEngine + Send + Sync + 'static, PA: PolicyAgent + Send + Sync + 'static,

pub fn new_weak_node<SE, PA>( node: &Node<SE, PA>, collection_id: CollectionId, args: MatchArgs, cdata: PA::ContextData, ) -> Result<Self, RetrievalError>

where SE: StorageEngine + Send + Sync + 'static, PA: PolicyAgent + Send + Sync + 'static,

Create a LiveQuery that does NOT keep the node alive.

Used by PolicyAgent and other internal subscribers that should not create reference cycles (node → agent → livequery → node). Operations that need the node (activation, selection updates) fail with “Node has been dropped” once the node is gone.

pub fn map<R: View>(self) -> LiveQuery<R>

pub async fn wait_initialized(&self)

Wait for the LiveQuery to be fully initialized with initial states

pub fn update_selection( &self, new_selection: impl TryInto<Selection, Error = impl Into<RetrievalError>>, ) -> Result<(), RetrievalError>

pub async fn update_selection_wait( &self, new_selection: impl TryInto<Selection, Error = impl Into<RetrievalError>>, ) -> Result<(), RetrievalError>

pub fn error(&self) -> Read<Option<RetrievalError>>

pub fn query_id(&self) -> QueryId

pub fn selection(&self) -> Read<(Selection, u32)>

pub fn resultset(&self) -> EntityResultSet

pub fn weak(&self) -> WeakEntityLiveQuery

Create a weak reference to this LiveQuery

Trait Implementations

impl Clone for EntityLiveQuery

fn clone(&self) -> EntityLiveQuery

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.