Function dendrite_auth::dendrite::axon_utils::command_worker
source · pub async fn command_worker(
axon_server_handle: AxonServerHandle,
aggregate_registry: &mut TheAggregateRegistry,
worker_control: WorkerControl
) -> Result<(), Error>
Expand description
Subscribes to commands, verifies them against the command projection and sends emitted events to AxonServer.