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

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 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) -> Option<RetrievalError>

pub fn query_id(&self) -> QueryId

pub fn weak(&self) -> WeakEntityLiveQuery

Create a weak reference to this LiveQuery

pub fn mark_initialized(&self, version: u32)

Mark initialization as complete for a given version

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.

impl PreNotifyHook for &EntityLiveQuery

fn pre_notify(&self, version: u32)