有一个类,它有可观察的字段。我要更新localData
接收远程数据时remoteData
,由于某种原因我无法获取 localData
中的数据,调试不会到断点,甚至到 getIdsInDatumsRemote ()
。 identifyDatumsForUpdate ()
方法获取一个空的 Observable。
class DiskDatumDataStore {
var remoteData: Observable<Data>? = null
var localData: Observable<Data>? = null
override fun sync() {
remoteDatums = getChangedRemoteData(lastUpdated!!, 1000)!!
localDatums = remoteDatums!!.map {
getIdsInDatumsRemote(it)
}.map {
it.map {
it.toLong()
}
}.flatMap {
getOldLocalData(it)
}
identifyDatumsForUpdate(datumsForUpdateLocal, datumsForUpdateRemote)
}
override fun getOldLocalData(remoteDatumsIds: List<Long>): Observable<List<DataLayerTypesOfResponsibility>> {
return Observable.fromCallable { repository.getOldDatum(remoteDatumsIds) }
}
}
最佳答案
您没有订阅
您的Observable
。您只是在创建它。
localDatums = remoteDatums!!.map {
getIdsInDatumsRemote(it)
}.map {
it.map {
it.toLong()
}
}.flatMap {
getOldLocalData(it)
}.subscribe { it->
//do something with the result `it`
}
关于java - 一个 Observable 对另一个 RxJava2 的依赖,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/57251465/