Skip to content

Commit

Permalink
detekt
Browse files Browse the repository at this point in the history
  • Loading branch information
Mr3zee committed Feb 13, 2025
1 parent 0e8255d commit b061e12
Showing 1 changed file with 3 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -21,6 +21,7 @@ class KrpcTestServiceBackend(override val coroutineContext: CoroutineContext) :
const val SHARED_FLOW_REPLAY = 5
}

@Suppress("detekt.EmptyFunctionBlock")
override suspend fun empty() {}

override suspend fun returnType(): String {
Expand Down Expand Up @@ -156,8 +157,8 @@ class KrpcTestServiceBackend(override val coroutineContext: CoroutineContext) :
}

override suspend fun streamInStreamWithStream(payloadWithPayload: Flow<PayloadWithPayload>): Int {
payloadWithPayload.collectIndexed { index, it ->
assertContentEquals(KrpcTransportTestBase.expectedPayloadWithPayload(index), it.collect())
payloadWithPayload.collectIndexed { index, payload ->
assertContentEquals(KrpcTransportTestBase.expectedPayloadWithPayload(index), payload.collect())
}
return 5
}
Expand Down

0 comments on commit b061e12

Please sign in to comment.