Function dendrite::axon_utils::query_processor [−][src]
pub async fn query_processor<Q: QueryContext + Send + Sync + Clone>(
axon_server_handle: AxonServerHandle,
query_context: Q,
query_handler_registry: TheHandlerRegistry<Q, QueryResult>
) -> Result<()>
Subscribes to queries, executes them against a query model and pass back the results.