test(jetbrains): coordinate SSE callback contention

This commit is contained in:
kirillk
2026-06-03 18:37:02 -04:00
parent e8b3f5e8bf
commit 806a2e6147
@@ -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()