test: stabilize PR checks

This commit is contained in:
kirillk
2026-06-03 16:37:02 -04:00
parent 454b1a2197
commit 01df91d871
3 changed files with 8 additions and 1 deletions
@@ -25,6 +25,7 @@ import okhttp3.sse.EventSourceListener
import java.util.concurrent.CountDownLatch
import java.util.concurrent.TimeUnit
import java.util.concurrent.atomic.AtomicInteger
import java.util.concurrent.atomic.AtomicReference
import kotlin.test.AfterTest
import kotlin.test.Test
import kotlin.test.assertEquals
@@ -138,6 +139,11 @@ class KiloConnectionServiceTest {
override fun request(): Request = Request.Builder().url("http://127.0.0.1/global/event").build()
override fun cancel() {}
}
val sourceField = KiloConnectionService::class.java.getDeclaredField("source")
sourceField.isAccessible = true
@Suppress("UNCHECKED_CAST")
val ref = sourceField.get(svc) as AtomicReference<EventSource?>
ref.set(source)
val received = scope.async {
withTimeout(5_000) {
svc.events.take(2).toList()
@@ -899,7 +899,7 @@ it.live(
}),
{ git: true, config: providerCfg },
),
3_000,
10_000, // kilocode_change - Windows CI can need extra time to settle cancellation
)
unix(
+1
View File
@@ -1,4 +1,5 @@
#!/usr/bin/env sh
# kilocode_change - new file
set -eu
usage() {