Struct dittolive_ditto::store::live_query::LiveQuery

pub struct LiveQuery {
    pub query: Box,
    pub collection_name: Box,
    pub subscription: Option<Box<Subscription>>,
    pub event_handler: Pin<Box<dyn EventHandler>>,
    pub id: i64,
    /* private fields */
}

Fields

query: Box

collection_name: Box

subscription: Option<Box<Subscription>>

If created via observe contains the associated Subscription for the LiveQuery

event_handler: Pin<Box<dyn EventHandler>>

An OWNED event handler, which is borrowed on the other side of the FFI. As such, retain and release methods for the handler can be None.

id: i64

Implementations

impl LiveQuery

pub fn with_handler<F>(
    ditto: Arc<BoxedDitto>,
    query: Box,
    query_args: Option<Vec<u8>>,
    collection_name: Box,
    order_by: &[COrderByParam<'_>],
    limit: i32,
    offset: u32,
    subscription: Option<Box<Subscription>>,
    event_handler: F
) -> Result<Self, DittoError> where
    F: EventHandler, 

Trait Implementations

impl Drop for LiveQuery

fn drop(self: &mut LiveQuery)

Executes the destructor for this type.

impl Observer for LiveQuery

fn stop(self)

Stop the observer to no longer receive updates