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

musikr: fix stuck evaluate step

Browse source
This commit is contained in:
Alexander Capehart 2024-12-17 11:27:14 -05:00
parent 6850a3443f
commit 8bbb7497a6
No known key found for this signature in database
GPG key ID: 37DBE3621FE9AD47
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
musikr/src/main/java/org/oxycblt/musikr/pipeline/EvaluateStep.kt
View file

@ -69,16 +69,17 @@ private class EvaluateStepImpl(
val preSongs = val preSongs =
rawSongs rawSongs
.map { tagInterpreter.interpret(it, interpretation) } .map { tagInterpreter.interpret(it, interpretation) }
.flowOn(Dispatchers.Main) .flowOn(Dispatchers.Default)
.buffer(Channel.UNLIMITED) .buffer(Channel.UNLIMITED)
val prePlaylists = val prePlaylists =
filterFlow.left filterFlow.left
.map { playlistInterpreter.interpret(it, interpretation) } .map { playlistInterpreter.interpret(it, interpretation) }
.flowOn(Dispatchers.Main) .flowOn(Dispatchers.Default)
.buffer(Channel.UNLIMITED) .buffer(Channel.UNLIMITED)
val graphBuilder = MusicGraph.builder() val graphBuilder = MusicGraph.builder()
val graphBuild = val graphBuild =
merge( merge(
filterFlow.manager,
preSongs.onEach { graphBuilder.add(it) }, preSongs.onEach { graphBuilder.add(it) },
prePlaylists.onEach { graphBuilder.add(it) }) prePlaylists.onEach { graphBuilder.add(it) })
graphBuild.collect() graphBuild.collect()