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>where
    Q: QueryContext + Send + Sync + Clone,

Expand description

Subscribes to queries, executes them against a query model and pass back the results.