Skip to content

Commit 7962f9b

Browse files
committed
Fix detekt issues
1 parent 0d3b011 commit 7962f9b

File tree

2 files changed

+1
-11
lines changed

2 files changed

+1
-11
lines changed

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

Lines changed: 0 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -6,19 +6,12 @@ package kotlinx.rpc.krpc
66

77
import kotlinx.atomicfu.atomic
88
import kotlinx.coroutines.CoroutineScope
9-
import kotlinx.coroutines.Dispatchers
10-
import kotlinx.coroutines.ExperimentalCoroutinesApi
119
import kotlinx.coroutines.Job
1210
import kotlinx.coroutines.cancelAndJoin
1311
import kotlinx.coroutines.channels.Channel
14-
import kotlinx.coroutines.delay
1512
import kotlinx.coroutines.job
16-
import kotlinx.coroutines.joinAll
17-
import kotlinx.coroutines.launch
1813
import kotlinx.coroutines.test.TestResult
1914
import kotlinx.coroutines.test.TestScope
20-
import kotlinx.coroutines.withContext
21-
import kotlinx.coroutines.yield
2215
import kotlinx.rpc.krpc.internal.HandlerKey
2316
import kotlinx.rpc.krpc.internal.KrpcActingReceiveHandler
2417
import kotlinx.rpc.krpc.internal.KrpcCallMessage
@@ -29,20 +22,16 @@ import kotlinx.rpc.krpc.internal.KrpcMessageSender
2922
import kotlinx.rpc.krpc.internal.KrpcMessageSubscription
3023
import kotlinx.rpc.krpc.internal.KrpcPluginKey
3124
import kotlinx.rpc.krpc.internal.KrpcReceiveBuffer
32-
import kotlinx.rpc.krpc.internal.KrpcSendHandler
3325
import kotlinx.rpc.krpc.internal.KrpcStoringReceiveHandler
3426
import kotlinx.rpc.krpc.internal.WindowResult
3527
import kotlinx.rpc.krpc.internal.decodeWindow
3628
import kotlinx.rpc.krpc.internal.deserialize
3729
import kotlinx.rpc.krpc.internal.isFailure
3830
import kotlinx.rpc.krpc.internal.isSuccess
39-
import kotlinx.rpc.krpc.internal.onClosed
40-
import kotlinx.rpc.krpc.internal.onFailure
4131
import kotlinx.rpc.test.runTestWithCoroutinesProbes
4232
import kotlin.test.Test
4333
import kotlin.test.assertEquals
4434
import kotlin.test.assertTrue
45-
import kotlin.test.fail
4635
import kotlin.time.Duration
4736
import kotlin.time.Duration.Companion.seconds
4837

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -271,6 +271,7 @@ internal class KrpcServerService<@Rpc T : Any>(
271271
connector.sendMessage(result)
272272
}
273273

274+
@Suppress("detekt.ThrowsCount")
274275
private suspend fun sendFlowMessages(
275276
serialFormat: SerialFormat,
276277
returnSerializer: KSerializer<Any?>,

0 commit comments

Comments
 (0)