[][src]Function dendrite::axon_utils::query_processor

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.