third-party-mirrors/ultrasonic
1
0
Fork 0
mirror of https://gitlab.com/ultrasonic/ultrasonic.git synced 2025-05-20 01:01:32 +03:00
Code Issues Packages Projects Releases Wiki Activity

Apply 1 suggestion(s) to 1 file(s)

Browse Source
This commit is contained in:
Alex Katlein 2023-07-24 17:43:03 +00:00 committed by birdbird
parent 8d43b935ab
commit eab55a7837
1 changed files with 16 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
ultrasonic/src/main/kotlin/org/moire/ultrasonic/service/MediaPlayerManager.kt
View File

@ -181,22 +181,23 @@ class MediaPlayerManager(
createMediaController(onCreated) createMediaController(onCreated)
rxBusSubscription += RxBus.activeServerChangingObservable.subscribe { oldServer -> rxBusSubscription +=
// Even though Rx should launch on the main thread it doesn't always :( RxBus
mainScope.launch { .activeServerChangingObservable
if (oldServer != OFFLINE_DB_ID) { .subscribeOn(AndroidSchedulers.mainThread())
// When the server changes, the playlist can retain the downloaded songs. .subscribe { oldServer ->
// Incomplete songs should be removed as the new server won't recognise them. if (oldServer != OFFLINE_DB_ID) {
removeIncompleteTracksFromPlaylist() // When the server changes, the playlist can retain the downloaded songs.
DownloadService.requestStop() // Incomplete songs should be removed as the new server won't recognise them.
removeIncompleteTracksFromPlaylist()
DownloadService.requestStop()
}
if (controller is JukeboxMediaPlayer) {
// When the server changes, the Jukebox should be released.
// The new server won't understand the jukebox requests of the old one.
switchToLocalPlayer()
}
} }
if (controller is JukeboxMediaPlayer) {
// When the server changes, the Jukebox should be released.
// The new server won't understand the jukebox requests of the old one.
switchToLocalPlayer()
}
}
}
rxBusSubscription += RxBus.activeServerChangedObservable.subscribe { rxBusSubscription += RxBus.activeServerChangedObservable.subscribe {
val jukebox = activeServerProvider.getActiveServer().jukeboxByDefault val jukebox = activeServerProvider.getActiveServer().jukeboxByDefault