重复查询db & rxjava observableResult多次调用后续函数
重复查询db & rxjava observableResult多次调用后续函数
提问于 2017-06-22 12:43:09
在android上，我正在使用requery db，并尝试将我的DB更改上传到服务器。为了实现同样的目的，我运行以下逻辑
Scheduler sub2 = Schedulers.newThread();
Scheduler ob2 = Schedulers.newThread();
data.select(Broadcaster.class)
.where(Broadcaster.IS_DIRTY.eq(true))
.get()
.observableResult()
.subscribeOn(sub2)
.observeOn(ob2)
.flatMap(broadcasters->broadcasters.observable())
.flatMap(broadcasters->Backend.getInstance()
.uploadBroadcaster(broadcasters)
.onExceptionResumeNext(Observable.empty()))
.flatMapSingle(broadcaster -> markUploaded(broadcaster))
.doOnError(t->Log.e(TAG,"Error uploading ",t))
.subscribe();但是，对于每个更改，都会使用相同的数据多次(4-10次)调用uploadBroadcaster。我到底做错了什么。
回答 1
Stack Overflow用户
回答已采纳
发布于 2017-06-22 13:52:02
这是我的错。这段代码被多次调用。所以订阅发生了多次。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/44690311
复制相关文章
相似问题
腾讯云开发者
