From 746dc2dc678a21f1dbf4593df92483284c558809 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Brage=20Skj=C3=B8nborg?= Date: Thu, 22 Jan 2026 03:59:14 +0100 Subject: [PATCH] Shift --- .../no/iktdev/eventi/events/EventPollerImplementation.kt | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/src/main/kotlin/no/iktdev/eventi/events/EventPollerImplementation.kt b/src/main/kotlin/no/iktdev/eventi/events/EventPollerImplementation.kt index e23de25..c76dd2d 100644 --- a/src/main/kotlin/no/iktdev/eventi/events/EventPollerImplementation.kt +++ b/src/main/kotlin/no/iktdev/eventi/events/EventPollerImplementation.kt @@ -51,16 +51,15 @@ abstract class EventPollerImplementation( // Samle persistedAt KUN for referanser vi faktisk dispatch’et val processedTimes = mutableListOf() - for ((referenceId, eventsForRef) in grouped) { + for ((referenceId, _) in grouped) { if (dispatchQueue.isProcessing(referenceId)) { log.debug { "Skipping dispatch for $referenceId as it is already being processed" } continue } val fullLog = eventStore.getPersistedEventsFor(referenceId) - processedTimes += fullLog.map { it.persistedAt } - val events = fullLog.mapNotNull { it.toEvent() } + processedTimes += fullLog.map { it.persistedAt } dispatchQueue.dispatch(referenceId, events, dispatcher) }