From 8f06f8682d66ddaf7d3ed52f2b89a0782ef824ec Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Brage=20Skj=C3=B8nborg?= Date: Fri, 30 Jan 2026 14:27:09 +0100 Subject: [PATCH] Blocking collect on collect --- .../coordinator/listeners/events/CollectEventsListener.kt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/listeners/events/CollectEventsListener.kt b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/listeners/events/CollectEventsListener.kt index b178d6e8..df395d11 100644 --- a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/listeners/events/CollectEventsListener.kt +++ b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/listeners/events/CollectEventsListener.kt @@ -17,7 +17,7 @@ class CollectEventsListener: EventListener() { history: List ): Event? { // Prevent Rouge trigger when replayed - if (history.any { it is CollectedEvent }) return null + if (event is CollectedEvent || history.any { it is CollectedEvent }) return null val collectProjection = CollectProjection(history) log.info { collectProjection.prettyPrint() }