Function dendrite_auth::dendrite::axon_utils::event_processor

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

Subscribes to events and builds a query model from them.

There are likely to be multiple query models for a single application.