Fix linter error

kamu-data · Jan 7, 2025 · 350b5c3 · 350b5c3
1 parent 69f318c
commit 350b5c3
Showing 1 changed file with 10 additions and 10 deletions.
diff --git a/src/utils/event-sourcing/src/aggregate.rs b/src/utils/event-sourcing/src/aggregate.rs
@@ -137,16 +137,16 @@ where
             // When failed to read at least one event from source stream,
             // function returns error result immediately
             let (query, event_id, event) = res?;
-            let agg_result: Result<Aggregate<Proj, Store>, LoadError<Proj>> =
-                match agg_results.remove(&query) {
-                    None => Self::from_stored_event(query.clone(), event_id, event)
-                        .map_err(|err| err.into()),
-                    Some(Ok(mut agg)) => match agg.apply_stored(event_id, event) {
-                        Ok(_) => Ok(agg),
-                        Err(err) => Err(err.into()),
-                    },
-                    Some(Err(err)) => Err(err),
-                };
+            let agg_result: Result<Aggregate<Proj, Store>, LoadError<Proj>> = match agg_results
+                .remove(&query)
+            {
+                None => Self::from_stored_event(query.clone(), event_id, event).map_err(Into::into),
+                Some(Ok(mut agg)) => match agg.apply_stored(event_id, event) {
+                    Ok(_) => Ok(agg),
+                    Err(err) => Err(err.into()),
+                },
+                Some(Err(err)) => Err(err),
+            };
             agg_results.insert(query, agg_result);
         }