Struct LiveQuery 

pub struct LiveQuery<R: View>(/* private fields */);

Implementations

impl<R: View> LiveQuery<R>

pub async fn wait_initialized(&self)

Wait for the LiveQuery to be fully initialized with initial states

pub fn resultset(&self) -> ResultSet<R>

pub fn loaded(&self) -> bool

pub fn ids(&self) -> Vec<EntityId>

pub fn ids_sorted(&self) -> Vec<EntityId>

Methods from Deref<Target = EntityLiveQuery>

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<R: Clone + View> Clone for LiveQuery<R>

fn clone(&self) -> LiveQuery<R>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<R: View> Deref for LiveQuery<R>

type Target = EntityLiveQuery

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<R: View + Clone + 'static> Get<Vec<R>> for LiveQuery<R>

fn get(&self) -> Vec<R>

impl<R: View + Clone + 'static> Peek<Vec<R>> for LiveQuery<R>

fn peek(&self) -> Vec<R>

impl<R: View> Signal for LiveQuery<R>

fn listen(&self, listener: Listener) -> ListenerGuard

Listen to changes to this signal with a listener function

fn broadcast_id(&self) -> BroadcastId

Get the broadcast identifier for this signal. Multiple signals may return the same broadcast_id if they share a broadcast. The broadcast_id remains valid as a deduplication key as long as any ListenerGuard for that broadcast exists.

impl<R> Subscribe<ChangeSet<R>> for LiveQuery<R>

where R: Clone + Send + Sync + 'static + View,

fn subscribe<L>(&self, listener: L) -> SubscriptionGuard

where L: IntoSubscribeListener<ChangeSet<R>>,

Subscribe to changes with a listener that receives the new value