[][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.