Remove mains and migrations from examples

CHANGELOG.md

@@ -19,7 +19,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
   - `AggregateState::new` second parameter from `Uuid` to `impl Into<Uuid>`.
   - `AggregateManager::load` first parameter from `Uuid` to `impl Into<Uuid>`.
   - `AggregateState::delete` first parameter from `Uuid` to `impl Into<Uuid>`.
-
+- [[#118]]: Merged rebuild examples into one; removed mains and migrations from examples.
 ---
 
 ## [0.7.0]

Cargo.toml

@@ -17,8 +17,7 @@ members = [
     "examples/customize_persistence_flow",
     "examples/delete_aggregate",
     "examples/dyn_event_store_in_aggregate",
-    "examples/rebuild_shared_projection",
-    "examples/rebuilder",
+    "examples/rebuild_strategies",
     "examples/simple_projection",
     "examples/simple_saga",
     "examples/simple_side_effect",

examples/customize_persistence_flow/src/aggregate.rs

@@ -62,6 +62,7 @@ impl AggregateManager for CounterAggregate {
         aggregate_state: &AggregateState<Self::State>,
         events: Vec<Self::Event>,
     ) -> Result<Vec<StoreEvent<Self::Event>>, Self::Error> {
+        // Here is the persistence flow customization.
         self.event_store
             .persist(|pool| async move {
                 let mut connection: PoolConnection<Postgres> = pool.acquire().await?;
@@ -91,7 +92,8 @@ impl AggregateManager for CounterAggregate {
 
                 for store_event in store_events.iter() {
                     for policy in self.event_store.policies().iter() {
-                        // We want to just log errors instead of return them
+                        // We want to just log errors instead of return them. This is the customization
+                        // we wanted.
                         match policy.handle_event(store_event).await {
                             Ok(_) => (),
                             Err(error) => println!("{:?}", error),