musikr: fix incorrect cache cleanups
This commit is contained in:
parent
73b2b92180
commit
63227a1f1f
1 changed files with 12 additions and 2 deletions
|
@ -99,12 +99,22 @@ private class ExtractStepImpl(
|
||||||
it.song.cover?.id,
|
it.song.cover?.id,
|
||||||
it.song.addedMs)
|
it.song.addedMs)
|
||||||
cache.write(cachedSong)
|
cache.write(cachedSong)
|
||||||
exclude.add(cachedSong)
|
|
||||||
Finalized(it.song)
|
Finalized(it.song)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
.map { it.extracted }
|
.map {
|
||||||
|
if (it.extracted is RawSong) {
|
||||||
|
exclude.add(
|
||||||
|
CachedSong(
|
||||||
|
it.extracted.file,
|
||||||
|
it.extracted.properties,
|
||||||
|
it.extracted.tags,
|
||||||
|
it.extracted.cover?.id,
|
||||||
|
it.extracted.addedMs))
|
||||||
|
}
|
||||||
|
it.extracted
|
||||||
|
}
|
||||||
.flowOn(Dispatchers.IO)
|
.flowOn(Dispatchers.IO)
|
||||||
.buffer(Channel.UNLIMITED)
|
.buffer(Channel.UNLIMITED)
|
||||||
.onCompletion { cache.cleanup(exclude) }
|
.onCompletion { cache.cleanup(exclude) }
|
||||||
|
|
Loading…
Reference in a new issue