Trait TNodeErased 

pub trait TNodeErased<E: AbstractEntity + Filterable + Send + 'static = Entity>:
    Send
    + Sync
    + 'static {
    // Required methods
    fn unsubscribe_remote_predicate(&self, query_id: QueryId);
    fn update_remote_query(
        &self,
        query_id: QueryId,
        selection: Selection,
        version: u32,
    ) -> Result<(), Error>;
    fn fetch_entities_from_local<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        collection_id: &'life1 CollectionId,
        selection: &'life2 Selection,
    ) -> Pin<Box<dyn Future<Output = Result<Vec<E>, RetrievalError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;
    fn reactor(&self) -> &Reactor<E>;
    fn has_subscription_relay(&self) -> bool;
}

Required Methods

fn unsubscribe_remote_predicate(&self, query_id: QueryId)

fn update_remote_query( &self, query_id: QueryId, selection: Selection, version: u32, ) -> Result<(), Error>

fn fetch_entities_from_local<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, collection_id: &'life1 CollectionId, selection: &'life2 Selection, ) -> Pin<Box<dyn Future<Output = Result<Vec<E>, RetrievalError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn reactor(&self) -> &Reactor<E>

fn has_subscription_relay(&self) -> bool

Implementors

impl<SE, PA> TNodeErased for Node<SE, PA>

where SE: StorageEngine + Send + Sync + 'static, PA: PolicyAgent + Send + Sync + 'static,