From 98437a0891f8609243f6d4c1a246463ca6376b24 Mon Sep 17 00:00:00 2001 From: bskjon Date: Sat, 19 Apr 2025 02:30:00 +0200 Subject: [PATCH] Correction to filter+++ --- .../kotlin/no/iktdev/eventi/implementations/EventCoordinator.kt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/shared/eventi/src/main/kotlin/no/iktdev/eventi/implementations/EventCoordinator.kt b/shared/eventi/src/main/kotlin/no/iktdev/eventi/implementations/EventCoordinator.kt index 58692ab7..bf93d147 100644 --- a/shared/eventi/src/main/kotlin/no/iktdev/eventi/implementations/EventCoordinator.kt +++ b/shared/eventi/src/main/kotlin/no/iktdev/eventi/implementations/EventCoordinator.kt @@ -94,7 +94,7 @@ abstract class EventCoordinator> { } val bashed = bashingReferenceObject[referenceId]?.takeLast(10) ?: emptyList() - if (bashed.size == 10 && bashed.all { it == bashed.first() }) { + if (bashed.size == 10 && bashed.all { it.first == bashed.first().first }) { // We have entered a deadlock here // Due to the nature of the deadlock the event will be determined to be dead log.error { "Producing Failure on $referenceId on event ${event.eventType} due to deadlock in $listenerName" }