minor change in ktor tcp

Author: whyoleg

rsocket-transports/ktor-tcp/src/commonMain/kotlin/io/rsocket/kotlin/transport/ktor/tcp/KtorTcpClientTransport.kt

@@ -97,7 +97,7 @@ private class KtorTcpClientTargetImpl(
         return withContext(Dispatchers.IoCompatible) {
             val socket = aSocket(selectorManager).tcp().connect(remoteAddress, socketOptions)
             KtorTcpConnection(
-                coroutineContext = this@KtorTcpClientTargetImpl.coroutineContext.childContext(),
+                parentContext = this@KtorTcpClientTargetImpl.coroutineContext,
                 socket = socket
             )
         }

rsocket-transports/ktor-tcp/src/commonMain/kotlin/io/rsocket/kotlin/transport/ktor/tcp/KtorTcpConnection.kt

@@ -28,12 +28,14 @@ import kotlin.coroutines.*
 
 @RSocketTransportApi
 internal class KtorTcpConnection(
-    override val coroutineContext: CoroutineContext,
+    parentContext: CoroutineContext,
     private val socket: Socket,
 ) : RSocketSequentialConnection {
     private val outboundQueue = PrioritizationFrameQueue(Channel.BUFFERED)
     private val inbound = bufferChannel(Channel.BUFFERED)
 
+    override val coroutineContext: CoroutineContext = parentContext.childContext()
+
     init {
         @OptIn(DelicateCoroutinesApi::class)
         launch(start = CoroutineStart.ATOMIC) {

rsocket-transports/ktor-tcp/src/commonMain/kotlin/io/rsocket/kotlin/transport/ktor/tcp/KtorTcpServerTransport.kt

@@ -129,7 +129,12 @@ private class KtorTcpServerInstanceImpl(
                 val connectionsContext = currentCoroutineContext().supervisorContext()
                 while (true) {
                     val socket = serverSocket.accept()
-                    onConnection(KtorTcpConnection(connectionsContext.childContext(), socket))
+                    onConnection(
+                        KtorTcpConnection(
+                            parentContext = connectionsContext,
+                            socket = socket
+                        )
+                    )
                 }
             } finally {
                 nonCancellable {