Fix weird issue on K/N

Author: Mr3zee

krpc/krpc-core/src/commonMain/kotlin/kotlinx/rpc/krpc/internal/ExceptionUtils.kt

@@ -4,7 +4,7 @@
 
 package kotlinx.rpc.krpc.internal
 
-import kotlinx.coroutines.CancellationException
+import kotlin.coroutines.cancellation.CancellationException
 import kotlinx.rpc.internal.rpcInternalTypeName
 import kotlinx.rpc.internal.utils.InternalRpcApi
 
@@ -13,8 +13,8 @@ public fun serializeException(cause: Throwable): SerializedException {
     val message = cause.message ?: "Unknown exception"
     val stacktrace = cause.stackElements()
     val serializedCause = cause.cause?.let { serializeException(it) }
-    val className = if (cause is CancellationException || cause is kotlin.coroutines.cancellation.CancellationException) {
-        CancellationException::class.rpcInternalTypeName ?: "kotlinx.coroutines.CancellationException"
+    val className = if (cause is kotlinx.coroutines.CancellationException || cause is CancellationException) {
+        CancellationException::class.rpcInternalTypeName ?: "kotlin.coroutines.cancellation.CancellationException"
     } else {
         cause::class.rpcInternalTypeName ?: ""
     }
@@ -27,8 +27,8 @@ internal expect fun Throwable.stackElements(): List<StackElement>
 internal expect fun SerializedException.deserializeUnsafe(): Throwable
 
 internal fun SerializedException.cancellationExceptionDeserialize(): CancellationException? {
-    if (className == CancellationException::class.rpcInternalTypeName
-        || className == kotlin.coroutines.cancellation.CancellationException::class.rpcInternalTypeName
+    if (className == kotlinx.coroutines.CancellationException::class.rpcInternalTypeName
+        || className == CancellationException::class.rpcInternalTypeName
     ) {
         val cause = this@cancellationExceptionDeserialize.cause?.deserializeUnsafe()
 

krpc/krpc-core/src/commonMain/kotlin/kotlinx/rpc/krpc/internal/KrpcReceiveBuffer.kt

@@ -5,7 +5,7 @@
 package kotlinx.rpc.krpc.internal
 
 import kotlinx.atomicfu.atomic
-import kotlinx.coroutines.CancellationException
+import kotlin.coroutines.cancellation.CancellationException
 import kotlinx.coroutines.channels.Channel
 
 internal class KrpcReceiveBuffer(
@@ -56,7 +56,13 @@ internal class KrpcReceiveBuffer(
 
     fun close(cause: Throwable?) {
         channel.close(cause)
-        channel.cancel(CancellationException(null, cause))
+
+        // There is some cringe here otherwise
+        // Overload resolution ambiguity between candidates:
+        // constructor(message: String?, cause: Throwable?): CancellationException
+        // expect fun CancellationException(message: String?, cause: Throwable?): CancellationException
+        @Suppress("CAST_NEVER_SUCCEEDS")
+        channel.cancel(CancellationException(cause) as kotlinx.coroutines.CancellationException)
 
         _inBuffer.getAndSet(_channelSize)
     }

krpc/krpc-core/src/commonMain/kotlin/kotlinx/rpc/krpc/internal/KrpcReceiveHandler.kt

@@ -5,7 +5,7 @@
 package kotlinx.rpc.krpc.internal
 
 import kotlinx.atomicfu.atomic
-import kotlinx.coroutines.CancellationException
+import kotlin.coroutines.cancellation.CancellationException
 import kotlinx.coroutines.CoroutineName
 import kotlinx.coroutines.CoroutineStart
 import kotlinx.coroutines.launch
@@ -186,10 +186,15 @@ internal class KrpcActingReceiveHandler(
 
     override fun close(key: HandlerKey<*>, e: Throwable?) {
         if (e != null) {
-            if (e is CancellationException) {
+            if (e is kotlinx.coroutines.CancellationException) {
                 job.cancel(e)
             } else {
-                job.cancel(CancellationException(null, e))
+                // There is some cringe here otherwise
+                // Overload resolution ambiguity between candidates:
+                // constructor(message: String?, cause: Throwable?): CancellationException
+                // expect fun CancellationException(message: String?, cause: Throwable?): CancellationException
+                @Suppress("CAST_NEVER_SUCCEEDS")
+                job.cancel(CancellationException(e) as kotlinx.coroutines.CancellationException)
             }
         } else {
             job.cancel()