Merge remote-tracking branch 'origin/main'

fraktalio · May 23, 2024 · 326d332 · 326d332
2 parents 7608d08 + 4935efe
commit 326d332
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/application/src/commonMain/kotlin/com/fraktalio/fmodel/application/EventSourcingAggregate.kt b/application/src/commonMain/kotlin/com/fraktalio/fmodel/application/EventSourcingAggregate.kt
@@ -45,7 +45,8 @@ interface EventOrchestratingComputation<C, S, E> : ISaga<E, C>, IDecider<C, S, E
         resultingEvents
             .flatMapConcat { react(it) }
             .onEach { c ->
-                val newEvents = flowOf(fetchEvents(c), resultingEvents)
+                val previousEvents = resultingEvents.toList().asFlow()
+                val newEvents = flowOf(fetchEvents(c), previousEvents)
                     .flattenConcat()
                     .computeNewEventsByOrchestrating(c, fetchEvents)
                 resultingEvents = flowOf(resultingEvents, newEvents).flattenConcat()