Struct QuerySubscription 

pub struct QuerySubscription<T>
where
    T: Clone + Send + 'static,
{ /* private fields */ }

A subscription to query results that updates when facts change.

QuerySubscription wraps a SignalStream but provides query-specific semantics. Results are re-evaluated and emitted when underlying facts change.

Implementations

impl<T> QuerySubscription<T>

where T: Clone + Send + 'static,

pub fn new( stream: SignalStream<T>, query_id: impl Into<String>, ) -> QuerySubscription<T>

Create a new query subscription

pub fn query_id(&self) -> &str

Get the query ID

pub fn try_recv(&mut self) -> Option<T>

Try to receive the next result without blocking

pub async fn recv(&mut self) -> Result<T, QueryError>

Receive the next result, waiting if necessary