Merge pull request #291 from fraktalio/feature/compute_events_by_orch…

…estrating Application module: Fixing bug in event computation - orchestrated scenario
fraktalio · May 17, 2024 · 4935efe · 4935efe
2 parents 6319f1e + b319835
commit 4935efe
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()