Function dendrite::axon_utils::command_worker[][src]

pub async fn command_worker(
    axon_server_handle: AxonServerHandle,
    aggregate_registry: &mut TheAggregateRegistry
) -> Result<()>

Subscribes to commands, verifies them against the command projection and sends emitted events to AxonServer.