Fabio/Auxio
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

music: use unlimited buffer for caching

Browse source
This commit is contained in:
Alexander Capehart 2024-11-29 16:32:17 -07:00
parent a3da28fb84
commit e647c31c56
No known key found for this signature in database
GPG key ID: 37DBE3621FE9AD47
1 changed files with 8 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
app/src/main/java/org/oxycblt/auxio/music/stack/explore/Explorer.kt
View file

@ -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 {