detekt

Author: Mr3zee

core/src/commonMain/kotlin/kotlinx/rpc/RpcClient.kt

@@ -44,13 +44,13 @@ public interface RpcClient : CoroutineScope {
     public fun <T> callAsync(serviceScope: CoroutineScope, call: RpcCall): Deferred<T>
 
     /**
-     * This method is used by generated clients to perform a call to the server.
+     * This method is used by generated clients to perform a call to the server
+     * that returns a streaming flow.
      *
      * @param T type of the result
-     * @param serviceScope service's coroutine scope
      * @param call an object that contains all required information about the called method,
      * that is needed to route it properly to the server.
-     * @return actual result of the call, for example, data from the server
+     * @return the actual result of the call, for example, data from the server
      */
     public fun <T> callServerStreaming(call: RpcCall): Flow<T> {
         error("Non-suspending server streaming is not supported by this client")

krpc/krpc-client/src/commonMain/kotlin/kotlinx/rpc/krpc/client/KrpcClient.kt

@@ -316,6 +316,7 @@ public abstract class KrpcClient(
 
     private val nonSuspendingSerialFormat = config.serialFormatInitializer.build()
 
+    @Suppress("detekt.CyclomaticComplexMethod")
     override fun <T> callServerStreaming(call: RpcCall): Flow<T> {
         return flow {
             awaitHandshakeCompletion()
@@ -363,8 +364,8 @@ public abstract class KrpcClient(
 
                         is KrpcCallMessage.CallSuccess, is KrpcCallMessage.StreamMessage -> {
                             val value = runCatching {
-                                val serializerResult =
-                                    nonSuspendingSerialFormat.serializersModule.rpcSerializerForType(callable.returnType)
+                                val serializerResult = nonSuspendingSerialFormat.serializersModule
+                                    .rpcSerializerForType(callable.returnType)
 
                                 decodeMessageData(nonSuspendingSerialFormat, serializerResult, message)
                             }

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

@@ -160,6 +160,7 @@ internal class KrpcServerService<@Rpc T : Any>(
                     .contains(KrpcPluginKey.NON_SUSPENDING_SERVER_FLOW_MARKER)
 
                 if (callable.isNonSuspendFunction && !markedNonSuspending) {
+                    @Suppress("detekt.MaxLineLength")
                     error(
                         "Server flow returned from non-suspend function but marked so by a client: ${descriptor.fqName}::$callableName." +
                                 "Probable cause is outdated client version, that does not support non-suspending flows, " +