今天我升级了Android Studio 3.1，它似乎增加了一些严格检查。其中一个检查是针对未存储在变量中的一次性RxJava2subscribe()调用的。例如，从我的Room数据库获取所有玩家列表：
Single.just(db)
.subscribeOn(Schedulers.io())
.subscribe(db -> db.playerDao().getAll());
一个大黄色块的结果和这个提示:
subscribe的结果未被使用
对于类似这样的一次性 Rx 调用，最佳实践是什么？我应该保留 Disposable 和 dispose() 完成请求吗？还是只需要 @SuppressLint 然后继续进行下一步操作？
这只影响 RxJava2 (io.reactivex)，RxJava (rx) 没有此 Lint。
当订阅未被处理时，IDE不知道它可能产生的影响，因此将其视为潜在的不安全因素。例如，您的Single可能包含网络调用，在执行过程中如果您的Activity被丢弃，则可能导致内存泄漏。
管理大量Disposable的便捷方法是使用CompositeDisposable;只需在封闭类中创建一个新的CompositeDisposable实例变量，然后将所有Disposables添加到CompositeDisposable中（使用RxKotlin，您可以将addTo(compositeDisposable)附加到所有Disposables）。最后，当您完成实例时，请调用compositeDisposable.dispose()。
这将消除lint警告，并确保正确管理Disposables。
在这种情况下，代码将如下所示：
CompositeDisposable compositeDisposable = new CompositeDisposable();
Disposable disposable = Single.just(db)
.subscribeOn(Schedulers.io())
.subscribe(db -> db.get(1)));
compositeDisposable.add(disposable); //IDE is satisfied that the Disposable is being managed.
disposable.addTo(compositeDisposable); //Alternatively, use this RxKotlin extension function.
compositeDisposable.dispose(); //Placed wherever we'd like to dispose our Disposables (i.e. in onDestroy()).
当Activity被销毁时，Disposables列表被清空，这样就行了。
io.reactivex.disposables.CompositeDisposable mDisposable;
mDisposable = new CompositeDisposable();
mDisposable.add(
Single.just(db)
.subscribeOn(Schedulers.io())
.subscribe(db -> db.get(1)));
mDisposable.dispose(); // dispose wherever is required
您可以使用DisposableSingleObserver进行订阅：
Single.just(db)
.subscribeOn(Schedulers.io())
.subscribe(new DisposableSingleObserver<Object>() {
@Override
public void onSuccess(Object obj) {
// work with the resulting todos...
dispose();
}
@Override
public void onError(Throwable e) {
// handle the error case...
dispose();
}});
如果需要直接处理Single对象（例如在其发出之前），您可以实现onSubscribe(Disposable d)方法以获取并使用Disposable引用。
您还可以自己实现SingleObserver接口或使用其他子类。
建议您可以使用全局 CompositeDisposable 将 subscribe 操作的结果添加到其中。
RxJava2Extensions 库包含有用的方法，可自动从 CompositeDisposable 中删除创建的 disposable（一次性资源） when it completes。请参见 subscribeAutoDispose 章节。
在您的情况下，可以像这样：
SingleConsumers.subscribeAutoDispose(
Single.just(db)
.subscribeOn(Schedulers.io()),
composite,
db -> db.playerDao().getAll())
dispose会导致内存泄漏，我认为这是一个太笼统的说法。在我看来，有关不存储subscribe结果的lint警告在某些情况下并不重要，因为：
由于我不想抑制lint警告，所以最近开始在同步可观察对象的情况下使用以下模式：
var disposable: Disposable? = null
disposable = Observable
.just(/* Whatever */)
.anyOperator()
.anyOtherOperator()
.subscribe(
{ /* onSuccess */ },
{ /* onError */ },
{
// onComplete
// Make lint happy. It's already disposed because the stream completed.
disposable?.dispose()
}
)
无论是对正确性的确认还是漏洞的发现，我都很希望听到您的评论关于这个问题。
.as。 Single.just(db)
.subscribeOn(Schedulers.io())
.as(AutoDispose.autoDisposable(AndroidLifecycleScopeProvider.from(this)))
.subscribe(db -> db.playerDao().getAll());
还有另一种可用的方法，就是避免手动使用Disposables（添加和删除订阅）。
您可以定义一个Observable，该Observable将从SubjectBehaviour（如果您使用RxJava）接收内容。通过将该observable传递给您的LiveData，应该可以解决问题。请查看以下基于初始问题的示例：
private val playerSubject: Subject<Player> = BehaviorSubject.create()
private fun getPlayer(idPlayer: String) {
playerSubject.onNext(idPlayer)
}
private val playerSuccessful: Observable<DataResult<Player>> = playerSubject
.flatMap { playerId ->
playerRepository.getPlayer(playerId).toObservable()
}
.share()
val playerFound: LiveData<Player>
get() = playerSuccessful
.filterAndMapDataSuccess()
.toLiveData()
val playerNotFound: LiveData<Unit>
get() = playerSuccessful.filterAndMapDataFailure()
.map { Unit }
.toLiveData()
// These are a couple of helpful extensions
fun <T> Observable<DataResult<T>>.filterAndMapDataSuccess(): Observable<T> =
filter { it is DataResult.Success }.map { (it as DataResult.Success).data }
fun <T> Observable<DataResult<T>>.filterAndMapDataFailure(): Observable<DataResult.Failure<T>> =
filter { it is DataResult.Failure }.map { it as DataResult.Failure<T> }
如果您确定已正确处理一次性操作，例如使用doOnSubscribe()运算符，则可以将以下内容添加到Gradle中：
android {
lintOptions {
disable 'CheckResult'
}}
@SuppressLint("CheckResult")来抑制警告。 - Victor Rendina
Disposable保留在成员范围内，并在单个完成时调用dispose()，但这似乎过于繁琐。我很想看看是否有更好的方法来解决这个问题。 - Michael Dodd