Function dendrite_auth::dendrite::axon_utils::query_processor
source · pub async fn query_processor<Q>(
axon_server_handle: AxonServerHandle,
query_context: Q,
query_handler_registry: TheHandlerRegistry<Q, QueryRequest, QueryResult>,
worker_control: WorkerControl
) -> Result<(), Error>
Expand description
Subscribes to queries, executes them against a query model and pass back the results.