From 806a2e6147fa66445a562e3548d596bd86480f18 Mon Sep 17 00:00:00 2001
From: kirillk <kirillk@kilocode.ai>
Date: Wed, 3 Jun 2026 18:37:02 -0400
Subject: [PATCH] test(jetbrains): coordinate SSE callback contention

---
 .../ai/kilocode/backend/app/KiloConnectionServiceTest.kt   | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/packages/kilo-jetbrains/backend/src/test/kotlin/ai/kilocode/backend/app/KiloConnectionServiceTest.kt b/packages/kilo-jetbrains/backend/src/test/kotlin/ai/kilocode/backend/app/KiloConnectionServiceTest.kt
index da92774fee9..335b91e2e87 100644
--- a/packages/kilo-jetbrains/backend/src/test/kotlin/ai/kilocode/backend/app/KiloConnectionServiceTest.kt
+++ b/packages/kilo-jetbrains/backend/src/test/kotlin/ai/kilocode/backend/app/KiloConnectionServiceTest.kt
@@ -147,11 +147,16 @@ class KiloConnectionServiceTest {
             }
         }
 
+        val entered = CountDownLatch(1)
         val first = Thread { listener.onEvent(source, null, "first.event", "first") }
-        val second = Thread { listener.onEvent(source, null, "second.event", "second") }
+        val second = Thread {
+            entered.countDown()
+            listener.onEvent(source, null, "second.event", "second")
+        }
         first.start()
         assertTrue(blocked.started.await(1, TimeUnit.SECONDS))
         second.start()
+        assertTrue(entered.await(1, TimeUnit.SECONDS))
         blocked.release.countDown()
         first.join()
         second.join()