close sending channel

DatL4g · Jul 20, 2024 · 9101c28 · 9101c28
1 parent 17d9961
commit 9101c28
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/commonMain/kotlin/dev/datlag/k2k/connect/ConnectionClient.kt b/src/commonMain/kotlin/dev/datlag/k2k/connect/ConnectionClient.kt
@@ -8,6 +8,7 @@ import io.ktor.network.sockets.InetSocketAddress
 import io.ktor.network.sockets.Socket
 import io.ktor.network.sockets.openWriteChannel
 import io.ktor.network.sockets.tcpNoDelay
+import io.ktor.utils.io.close
 import io.ktor.utils.io.writeFully
 
 internal class ConnectionClient(
@@ -35,6 +36,8 @@ internal class ConnectionClient(
         }.also {
             val channel = it.openWriteChannel(autoFlush = true)
             channel.writeFully(byteArray, 0, byteArray.size)
+            channel.flush()
+            channel.close()
         }
     }