[−][src]Function dendrite::axon_utils::event_processor
pub async fn event_processor<Q: TokenStore + Send + Sync + Clone>(
axon_server_handle: AxonServerHandle,
query_model: Q,
event_handler_registry: TheHandlerRegistry<Q, Option<Q>>
) -> Result<()>
Subscribes to events and builds a query model from them.
There are likely to be multiple query models for a single application.