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 eef67ec2..b8e4a048 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.any { it == bashed.first() }) { + if (bashed.all { it == bashed.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" }