使用Room、LiveData与RxAndroid时，LiveData持续输出旧Observable变更的解决咨询

你遇到的核心问题是每次切换歌曲ID时，旧的LiveData订阅没有被取消，导致多个LiveData的回调同时触发，干扰UI。这正是switchMap操作符的典型应用场景——它会自动取消前一个Observable的订阅，只保留最新的流的订阅。

先拆解下你现有代码的问题：

• 你在嵌套的subscribe里调用song.observe()，相当于每次ID变化都新增一个LiveData的生命周期订阅，但旧的订阅并没有被移除，所以旧歌曲的LiveData一旦有数据变更（比如数据库更新），还是会触发回调。
• 嵌套订阅不仅让代码逻辑混乱，也很难统一管理所有Disposable，容易引发内存泄漏和重复回调的问题。

正确解决方案：用switchMap+LiveDataReactiveStreams整合流 #

我们可以把LiveData转换成RxJava的Observable，再用switchMap来切换订阅，这样每次新ID出现时，自动取消旧的LiveData订阅，只监听当前歌曲的流。

具体步骤：

1. 用LiveDataReactiveStreams.fromPublisher()把Room返回的LiveData转换成Rx的Observable（或Flowable），让Rx操作符能直接管理它。
2. 用switchMap替代flatMap——switchMap的特性是：当源Observable（这里是ID的流）发射新值时，会立即取消之前订阅的Observable，转而订阅最新的那个。
3. 避免嵌套订阅，把整个流整合成链式调用，统一管理Disposable。

修改后的代码示例：

// 先确保引入依赖：implementation "androidx.lifecycle:lifecycle-reactivestreams:2.6.2"
import androidx.lifecycle.LiveDataReactiveStreams;
import io.reactivex.subjects.BehaviorSubject;

// 用BehaviorSubject来保存当前播放的歌曲ID，它会保留最新值，新订阅者能立即收到当前ID
BehaviorSubject<String> currentSongIdSubject = BehaviorSubject.createDefault(initialSongId);

mDisposable.add(
    currentSongIdSubject
        .switchMap(songId -> {
            // 将LiveData转换为Observable，自动适配生命周期订阅
            LiveData<Song> songLiveData = mViewModel.getLiveDataSong(songId);
            return LiveDataReactiveStreams.fromPublisher(songLiveData)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread());
        })
        .subscribe(
            liveSong -> {
                Log.d(TAG, "Live Song " + liveSong.toString());
                // 在这里更新UI，现在只会收到当前歌曲的更新回调
            },
            error -> Log.d(TAG, "Error " + error.getLocalizedMessage()),
            () -> Log.d(TAG, "Complete")
        )
);

// 当播放新歌曲时，只需发送新ID到Subject即可自动切换订阅
currentSongIdSubject.onNext(newSongId);

关键细节说明： #

• switchMap的核心作用：每次新ID发射时，它会自动取消之前从getLiveDataSong(oldId)转换来的Observable订阅，旧歌曲的LiveData从此不会再触发回调。
• LiveDataReactiveStreams的价值：它打通了LiveData和RxJava的流，同时会自动根据组件生命周期管理订阅（比如Activity销毁时自动取消），避免内存泄漏。
• 统一管理Disposable：现在整个流只有一个Disposable，不需要在嵌套订阅里重复添加，在onDestroy里调用mDisposable.dispose()就能一次性清理所有订阅。

额外建议： #

• 如果你的歌曲ID会频繁变化（比如用户连续切歌），用BehaviorSubject保存当前ID是最优选择，它能自动保留最新值，新订阅者会立即获取当前播放的歌曲ID。
• 确保mViewModel.getLiveDataSong(songId)返回的是对应ID的LiveData——Room的@Query返回的LiveData会自动监听数据库变化，所以当前歌曲的数据库数据更新时，你会收到最新的Song对象。

内容的提问来源于stack exchange，提问作者Andy Cass