We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent bbb7d46 commit 6f01c0cCopy full SHA for 6f01c0c
krpc/krpc-core/src/commonMain/kotlin/kotlinx/rpc/krpc/internal/KrpcReceiveHandler.kt
@@ -149,10 +149,15 @@ internal class KrpcActingReceiveHandler(
149
while (true) {
150
val (message, onMessageFailure) = storingHandler.receiveCatching().getOrNull() ?: break
151
152
- val result = withTimeoutOrNull(timeout) { tryHandle(message) }
153
- ?: HandlerResult.Failure(
+ val result = if (timeout == Duration.INFINITE) {
+ tryHandle(message)
154
+ } else {
155
+ withTimeoutOrNull(timeout) {
156
157
+ } ?: HandlerResult.Failure(
158
illegalStateException("Timeout while processing message")
159
)
160
+ }
161
162
if (result is HandlerResult.Failure) {
163
onMessageFailure(result.cause)
0 commit comments