change collecting condition

DatL4g · Jul 20, 2024 · 803be57 · 803be57
1 parent 8181c6c
commit 803be57
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/commonMain/kotlin/dev/datlag/k2k/connect/ConnectionServer.kt b/src/commonMain/kotlin/dev/datlag/k2k/connect/ConnectionServer.kt
@@ -48,10 +48,10 @@ internal class ConnectionServer(
                     suspendCatching {
                         val readChannel = boundSocket.openReadChannel()
                         val buffer = ByteArray(readChannel.availableForRead)
-                        while (true) {
+                        while (currentCoroutineContext().isActive) {
                             val bytesRead = readChannel.readAvailable(buffer)
                             if (bytesRead <= 0) {
-                                break
+                                continue
                             }
 
                             listener(buffer)