Fixed an issue where load() was called on background thread

Author: timusus

app/src/main/java/com/simplecity/amp_library/androidauto/AndroidAutoHelper.kt

@@ -18,6 +18,7 @@ import com.simplecity.amp_library.model.Song
 import com.simplecity.amp_library.utils.DataManager
 import com.simplecity.amp_library.utils.StringUtils
 import io.reactivex.Single
+import io.reactivex.android.schedulers.AndroidSchedulers
 
 sealed class MediaIdWrapper {
 
@@ -149,20 +150,23 @@ class MediaIdHelper {
                             .sortedBy { song -> song.albumName }
                             .sortedBy { song -> song.track }
                     }
+                    .observeOn(AndroidSchedulers.mainThread())
                     .subscribe(
                         { songs -> completion(songs, songs.indexOfFirst { it.id == mediaWrapper.songId }.or(0)) },
                         { completion(mutableListOf(), 0) }
                     )
             }
             is MediaIdWrapper.Playlist -> {
                 getSongsForPlaylistId(mediaWrapper.playlistId)
+                    .observeOn(AndroidSchedulers.mainThread())
                     .subscribe(
                         { songs -> completion(songs, 0) },
                         { completion(mutableListOf(), 0) }
                     )
             }
             is MediaIdWrapper.Genre -> {
                 getSongsForGenreId(mediaWrapper.genreId)
+                    .observeOn(AndroidSchedulers.mainThread())
                     .subscribe(
                         { songs -> completion(songs, 0) },
                         { completion(mutableListOf(), 0) }

app/src/main/java/com/simplecity/amp_library/playback/PlaybackManager.java

@@ -23,6 +23,7 @@
 import com.simplecity.amp_library.utils.LogUtils;
 import com.simplecity.amp_library.utils.SettingsManager;
 import com.simplecity.amp_library.utils.SleepTimer;
+import io.reactivex.android.schedulers.AndroidSchedulers;
 import io.reactivex.disposables.CompositeDisposable;
 import io.reactivex.schedulers.Schedulers;
 import java.util.List;
@@ -143,6 +144,7 @@ void playAutoShuffleList() {
             disposables.add(DataManager.getInstance().getSongsRelay()
                     .firstOrError()
                     .subscribeOn(Schedulers.io())
+                    .observeOn(AndroidSchedulers.mainThread())
                     .subscribe(songs -> {
                         queueManager.playlist = QueueItemKt.toQueueItems(songs);
                         queueManager.queuePosition = -1;