Struct QuerySubscriptionHandlers 

pub struct QuerySubscriptionHandlers {
    pub on_next: QueryResultCallback,
    pub on_error: Option<Arc<dyn Fn(&DataConnectError) + Send + Sync + 'static>>,
    pub on_complete: Option<Arc<dyn Fn() + Send + Sync + 'static>>,
}

Observer-style subscription handlers.

Fields

on_next: QueryResultCallback

on_error: Option<Arc<dyn Fn(&DataConnectError) + Send + Sync + 'static>>

on_complete: Option<Arc<dyn Fn() + Send + Sync + 'static>>

Implementations

impl QuerySubscriptionHandlers

pub fn new(on_next: QueryResultCallback) -> Self

pub fn with_error( self, callback: Arc<dyn Fn(&DataConnectError) + Send + Sync + 'static>, ) -> Self

pub fn with_complete( self, callback: Arc<dyn Fn() + Send + Sync + 'static>, ) -> Self

Trait Implementations

impl Clone for QuerySubscriptionHandlers

fn clone(&self) -> QuerySubscriptionHandlers

Returns a duplicate of the value.

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

Performs copy-assignment from source.