util: correctly throw channel errors

Wasn't being properly handled before, leading to weird behavior.
OxygenCobalt · Jan 1, 2024 · 77f0bbe · 77f0bbe
1 parent ed519ee
commit 77f0bbe
Showing 1 changed file with 1 addition and 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
@@ -186,7 +186,7 @@ suspend fun <E> ReceiveChannel<E>.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())