detekt

Author: Mr3zee

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

@@ -16,7 +16,6 @@ import kotlinx.coroutines.SupervisorJob
 import kotlinx.coroutines.cancel
 import kotlinx.coroutines.cancelAndJoin
 import kotlinx.coroutines.channels.Channel
-import kotlinx.coroutines.channels.ClosedSendChannelException
 import kotlinx.coroutines.coroutineScope
 import kotlinx.coroutines.currentCoroutineContext
 import kotlinx.coroutines.ensureActive

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

@@ -5,7 +5,6 @@
 package kotlinx.rpc.krpc.internal
 
 import kotlinx.coroutines.CoroutineName
-import kotlinx.coroutines.channels.ClosedSendChannelException
 import kotlinx.coroutines.launch
 import kotlinx.rpc.internal.utils.InternalRpcApi
 

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

@@ -8,7 +8,6 @@ import kotlinx.atomicfu.atomic
 import kotlinx.coroutines.CancellationException
 import kotlinx.coroutines.CoroutineName
 import kotlinx.coroutines.CoroutineStart
-import kotlinx.coroutines.channels.ClosedSendChannelException
 import kotlinx.coroutines.launch
 import kotlinx.coroutines.withTimeoutOrNull
 import kotlinx.rpc.internal.utils.InternalRpcApi

krpc/krpc-core/src/commonTest/kotlin/kotlinx/rpc/krpc/KrpcReceiveHandlerTest.kt

@@ -71,15 +71,15 @@ internal class KrpcReceiveHandlerTest : KrpcReceiveHandlerBaseTest() {
 
         acting.broadcastWindowUpdate(-1, null, "service", "callId")
         val windowResult2 = decodeWindow(channel.receive() as KrpcGenericMessage)
-        assertEquals(-1, (windowResult2 as  WindowResult.Success).update)
+        assertEquals(-1, (windowResult2 as WindowResult.Success).update)
 
         acting.broadcastWindowUpdate(Int.MAX_VALUE, null, "service", "callId")
         val windowResult3 = decodeWindow(channel.receive() as KrpcGenericMessage)
-        assertEquals(Int.MAX_VALUE, (windowResult3 as  WindowResult.Success).update)
+        assertEquals(Int.MAX_VALUE, (windowResult3 as WindowResult.Success).update)
 
         acting.broadcastWindowUpdate(Int.MIN_VALUE, null, "service", "callId")
         val windowResult4 = decodeWindow(channel.receive() as KrpcGenericMessage)
-        assertEquals(Int.MIN_VALUE, (windowResult4 as  WindowResult.Success).update)
+        assertEquals(Int.MIN_VALUE, (windowResult4 as WindowResult.Success).update)
     }
 
     @Test
@@ -172,7 +172,11 @@ internal class KrpcReceiveHandlerTest : KrpcReceiveHandlerBaseTest() {
                     withContext(Dispatchers.Default) {
                         delay(5.seconds)
                     }
-                    println("Collected: ${collected.size}, launches: ${counter.launches.value}, total: ${counter.total.value}")
+                    println(
+                        "Collected: ${collected.size}, " +
+                                "launches: ${counter.launches.value}, " +
+                                "total: ${counter.total.value}"
+                    )
                 }
             }
 

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

@@ -5,7 +5,6 @@
 package kotlinx.rpc.krpc.server.internal
 
 import kotlinx.coroutines.*
-import kotlinx.coroutines.channels.ClosedSendChannelException
 import kotlinx.coroutines.flow.Flow
 import kotlinx.rpc.annotations.Rpc
 import kotlinx.rpc.descriptor.RpcInvokator

krpc/krpc-test/src/commonMain/kotlin/kotlinx/rpc/krpc/test/KrpcTransportTestBase.kt

@@ -336,7 +336,9 @@ abstract class KrpcTransportTestBase {
     }
 
     @Test
-    fun RPC_should_be_able_to_receive_100_000_ints_with_batching_in_reasonable_time() = runTest(timeout = EXTENDED_TIMEOUT) {
+    fun RPC_should_be_able_to_receive_100_000_ints_with_batching_in_reasonable_time() = runTest(
+        timeout = EXTENDED_TIMEOUT,
+    ) {
         val n = iterations_100_000
         assertEquals(client.getNIntsBatched(n).last().last(), n)
     }