From 77f0bbe614d0312b82a9c5a70f6eb0c022a9e7db Mon Sep 17 00:00:00 2001 From: Alexander Capehart Date: Mon, 1 Jan 2024 12:01:13 -0700 Subject: [PATCH] util: correctly throw channel errors Wasn't being properly handled before, leading to weird behavior. --- app/src/main/java/org/oxycblt/auxio/util/StateUtil.kt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/app/src/main/java/org/oxycblt/auxio/util/StateUtil.kt b/app/src/main/java/org/oxycblt/auxio/util/StateUtil.kt index eb8358867..7ac5f632d 100644 --- a/app/src/main/java/org/oxycblt/auxio/util/StateUtil.kt +++ b/app/src/main/java/org/oxycblt/auxio/util/StateUtil.kt @@ -186,7 +186,7 @@ suspend fun ReceiveChannel.forEachWithTimeout( var subsequent = false val handler: suspend () -> Unit = { val value = receiveCatching() - if (value.isClosed) { + if (value.isClosed && value.exceptionOrNull() == null) { exhausted = true } else { action(value.getOrThrow())