Function dendrite_auth::dendrite::axon_utils::event_processor
source · pub async fn event_processor<Q>(
axon_server_handle: AxonServerHandle,
query_model: Q,
event_handler_registry: TheHandlerRegistry<Q, Event, Option<Q>>,
worker_control: WorkerControl
) -> Result<(), Error>
Expand description
Subscribes to events and builds a query model from them.
There are likely to be multiple query models for a single application.