detekt

Author: Mr3zee

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

@@ -13,7 +13,9 @@ 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) {
+    val className = if (
+        cause is CancellationException || cause is kotlin.coroutines.cancellation.CancellationException
+    ) {
         CancellationException::class.rpcInternalTypeName ?: "kotlinx.coroutines.CancellationException"
     } else {
         cause::class.rpcInternalTypeName ?: ""

krpc/krpc-server/src/commonMain/kotlin/kotlinx/rpc/krpc/server/internal/ServerStreamContext.kt

@@ -41,11 +41,13 @@ internal class ServerStreamContext {
     }
 
     suspend fun cancelStream(message: KrpcCallMessage.StreamCancel) {
-        streams[message.callId]?.get(message.streamId)?.channel?.sendIgnoreClosed(StreamCancel(message.cause.deserialize()))
+        streams[message.callId]?.get(message.streamId)?.channel
+            ?.sendIgnoreClosed(StreamCancel(message.cause.deserialize()))
     }
 
     suspend fun closeStream(message: KrpcCallMessage.StreamFinished) {
-        streams[message.callId]?.get(message.streamId)?.channel?.sendIgnoreClosed(StreamEnd)
+        streams[message.callId]?.get(message.streamId)?.channel
+            ?.sendIgnoreClosed(StreamEnd)
     }
 
     private suspend fun <T> Channel<T>.sendIgnoreClosed(data: T) {