From e647c31c5648df5a0c47ea3f89c92630f5c072ce Mon Sep 17 00:00:00 2001
From: Alexander Capehart <alex@oxycblt.org>
Date: Fri, 29 Nov 2024 16:32:17 -0700
Subject: [PATCH] music: use unlimited buffer for caching

---
 .../oxycblt/auxio/music/stack/explore/Explorer.kt    | 12 ++++++++----
 1 file changed, 8 insertions(+), 4 deletions(-)

diff --git a/app/src/main/java/org/oxycblt/auxio/music/stack/explore/Explorer.kt b/app/src/main/java/org/oxycblt/auxio/music/stack/explore/Explorer.kt
index 74bd493a4..58f8376d1 100644
--- a/app/src/main/java/org/oxycblt/auxio/music/stack/explore/Explorer.kt
+++ b/app/src/main/java/org/oxycblt/auxio/music/stack/explore/Explorer.kt
@@ -73,13 +73,17 @@ constructor(
                 }
                 .flowOn(Dispatchers.IO)
                 .buffer(Channel.UNLIMITED)
-        val cacheResults = tagCache.read(deviceFiles).flowOn(Dispatchers.IO).buffer()
+        val cacheResults =
+            tagCache.read(deviceFiles).flowOn(Dispatchers.IO).buffer(Channel.UNLIMITED)
         val audioFiles =
             cacheResults
-                .handleMisses {
+                .handleMisses { misses ->
                     val extracted =
-                        it.stretch(8) { tagExtractor.extract(it).flowOn(Dispatchers.IO) }.buffer()
-                    val written = tagCache.write(extracted).flowOn(Dispatchers.IO).buffer()
+                        misses
+                            .stretch(8) { tagExtractor.extract(it).flowOn(Dispatchers.IO) }
+                            .buffer(Channel.UNLIMITED)
+                    val written =
+                        tagCache.write(extracted).flowOn(Dispatchers.IO).buffer(Channel.UNLIMITED)
                     written
                 }
                 .onEach {