RxJava2 onNext() 多次调用？答案

【问题标题】：RxJava2 onNext() called multiple times?RxJava2 onNext() 多次调用？
【发布时间】：2018-07-11 08:28:26
【问题描述】：

我有一个返回 Observable 的方法，如下所示：

open fun get(): Observable<Response> {

    return if (condition)
        getDataFromApi()
    else
        getDataFromDb()

}

订阅如下：

                get()
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(/*a object of class extending DefaultObserver*/)

当调用 getDataFromDb() 并在一段时间后根据条件调用 getDataFromApi() 时，我遇到了这个问题。对于第一次调用，它工作正常，但在第二次调用 onNext 时，会使用来自 getDataFromDb() 的旧数据响应多次调用 onNext。请让我知道我做错了什么。我对 RxJava 有点陌生。

【问题讨论】：

尝试使用 Single
你怎么称呼这些？您是否检查过您的查询是否有可能从相应的数据源（RxJava 之外）过滤您想要的项目？
getDataFromApi() 调用 Retrofit 接口中的方法， getDataFromDb() 使用 RoomDao。然后在 ViewModel 中为片段调用它。

标签： android kotlin rx-java2 rx-kotlin2

【解决方案1】：

如果 getDataFromDb() 正在发射项目并且 getDataFromApi() 被调用，第一个方法将继续发射直到完成。如果不再需要，您应该取消订阅流，并在源中添加条件，以便在取消订阅 observable 时停止发射。

还要记住，observable 中的函数在订阅流之前不会运行。

【讨论】：

流已订阅。但是 getDataFromDb() 已经完成，它不会自行取消订阅。而且我使用匿名类扩展 DefaultObserver 进行订阅。