pub fn create_aggregate_definition<P>(
    projection_name: String,
    empty_projection: Box<fn() -> P>,
    command_handler_registry: TheHandlerRegistry<Arc<Mutex<AggregateContext<P>>>, Command, SerializedObject>,
    sourcing_handler_registry: TheHandlerRegistry<P, Event, P>
) -> AggregateDefinition<P>
where P: VecU8Message + Send + Sync + Clone,
Expand description

Creates a new aggregate definition as needed by function command_worker.