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 {