ruva-core 0.19.4

Rust Library For Event Driven TEvent Handling
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43

//!
//!
//! ### example - transaction unit of work
//! ```rust,no_run
//! impl<C, R> TCommandService<ServiceResponse, ServiceError> for CommandHandler<(C, R)>
//! where
//!     C: TCommand + for<'a> TGetHandler<&'a mut R, Result<ServiceResponse>>,
//!     R: TSetCurrentEvents + TUnitOfWork,
//! {
//!     async fn execute(&mut self) -> Result<ServiceResponse> {
//!         let CommandHandler((cmd, dep)) = self;
//!         dep.begin().await?;
//!
//!         match (C::get_handler())(cmd, &mut dep).await {
//!             Ok(val) => {
//!                 dep.commit().await?;
//!                 dep.close().await;
//!
//!                 Ok(val)
//!             }
//!             Err(err) => {
//!                 dep.rollback().await?;
//!                 dep.close().await;
//!                 if let ServiceError::StopSentinelWithEvent(event) = err {
//!                     dep.set_events(vec![event.clone()].into());
//!                     dep.process_internal_events().await?;
//!                     dep.process_external_events().await?;
//!                     Err(ServiceError::StopSentinelWithEvent(event))
//!                 } else {
//!                     Err(err)
//!                 }
//!             }
//!         }
//!     }
//! }
//! ```
//!

pub mod command;

pub mod event;
pub use command::*;
pub use event::*;