Trait artemis::exchange::Client

pub trait Client: Clone + Send + Sync + 'static {
    fn rerun_query(&self, query_key: u64);
    fn push_result<R>(&self, query_key: u64, result: ExchangeResult<R>)
    where
        R: DeserializeOwned + Send + Sync + Clone + 'static;
}

Client trait passed to exchanges. Only exposes methods useful to exchanges

Required methods

fn rerun_query(&self, query_key: u64)

Rerun a query with that key and push the result to all subscribers.

fn push_result<R>(&self, query_key: u64, result: ExchangeResult<R>) where
    R: DeserializeOwned + Send + Sync + Clone + 'static, 

Push a new result to any subscribers.

Loading content...

Implementations on Foreign Types

impl<M: Exchange> Client for Arc<ClientImpl<M>>

fn rerun_query(&self, query_key: u64)

fn push_result<R>(&self, key: u64, result: ExchangeResult<R>) where
    R: DeserializeOwned + Send + Sync + Clone + 'static, 

Loading content...

Implementors

Loading content...