Struct CommandHandlerGrpc 

pub struct CommandHandlerGrpc<S, H>
where
    S: Default + Send + Sync + 'static,
    H: CommandHandlerDomainHandler<State = S> + Clone + 'static,
{ /* private fields */ }

gRPC command handler service implementation.

Wraps a CommandHandlerRouter to handle commands. Optionally supports Replay RPC for MERGE_COMMUTATIVE conflict detection.

Implementations

impl<S, H> CommandHandlerGrpc<S, H>

where S: Default + Send + Sync + 'static, H: CommandHandlerDomainHandler<State = S> + Clone + 'static,

pub fn new(router: CommandHandlerRouter<S, H>) -> Self

Create a new command handler from a router.

pub fn with_replay(self, packer: StatePacker<S>) -> Self

Enable Replay RPC support by providing a state packer.

pub fn router(&self) -> &CommandHandlerRouter<S, H>

Get the underlying router.

Trait Implementations

impl<S, H> CommandHandlerService for CommandHandlerGrpc<S, H>

where S: Default + Send + Sync + 'static, H: CommandHandlerDomainHandler<State = S> + Clone + 'static,

fn handle<'life0, 'async_trait>( &'life0 self, request: Request<ContextualCommand>, ) -> Pin<Box<dyn Future<Output = Result<Response<BusinessResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Process command and return business response (events or revocation request)

fn replay<'life0, 'async_trait>( &'life0 self, request: Request<ReplayRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ReplayResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Replay events to compute state (for conflict detection) Optional: only needed if aggregate supports MERGE_COMMUTATIVE