diff --git a/fleet/rpc.server/srcCommonMain/fleet/rpc/server/ServerRequestDispatcher.kt b/fleet/rpc.server/srcCommonMain/fleet/rpc/server/ServerRequestDispatcher.kt index 6d153881c1a2..10132d852b1f 100644 --- a/fleet/rpc.server/srcCommonMain/fleet/rpc/server/ServerRequestDispatcher.kt +++ b/fleet/rpc.server/srcCommonMain/fleet/rpc/server/ServerRequestDispatcher.kt @@ -59,7 +59,7 @@ class ServerRequestDispatcher(private val connectionListener: ConnectionListener broadcastSafely(TransportMessage.RouteOpened(route)) connectionListener?.onConnect(endpoint, route, socketId, presentableName) coroutineScope { - val connectionJob = launch { + val connectionJob = launch(Dispatchers.Unconfined) { receive.consumeEach { message -> when (message) { is TransportMessage.Envelope -> { diff --git a/fleet/rpc/srcCommonMain/fleet/rpc/core/TransportMessage.kt b/fleet/rpc/srcCommonMain/fleet/rpc/core/TransportMessage.kt index 2282fd24abdb..998ead730c03 100644 --- a/fleet/rpc/srcCommonMain/fleet/rpc/core/TransportMessage.kt +++ b/fleet/rpc/srcCommonMain/fleet/rpc/core/TransportMessage.kt @@ -21,7 +21,7 @@ sealed class TransportMessage { @Serializable @SerialName("envelope") - data class Envelope(val destination: UID, val origin: UID, val otelData: String? = null, val payload: String) : TransportMessage() + data class Envelope(val destination: UID, val origin: UID, val otelData: String? = null, val payload: String) : TransportMessage() fun serialize(): String { return Json.encodeToString(serializer, this)