Empty commandes

MAIF · Aug 5, 2024 · e29a36c · e29a36c
1 parent 619e9fe
commit e29a36c
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/thoth-core/src/main/java/fr/maif/eventsourcing/EventProcessorImpl.java b/thoth-core/src/main/java/fr/maif/eventsourcing/EventProcessorImpl.java
@@ -83,6 +83,9 @@ public int hashCode() {
 
     @Override
     public CompletionStage<InTransactionResult<List<Either<Error, ProcessingSuccess<S, E, Meta, Context, Message>>>>> batchProcessCommand(TxCtx ctx, List<C> commands) {
+        if (commands.isEmpty()) {
+            return CompletionStages.completedStage(new InTransactionResult<>(List.empty(), () -> CompletionStages.completedStage(Tuple.empty())));
+        }
         // Collect all states from db
         return aggregateStore.getAggregates(ctx, commands.filter(Command::hasId).map(c -> c.entityId().get()))
                 .thenCompose(states ->