我有一些有線問(wèn)題。當(dāng)我第一次訂閱時(shí)，它會(huì)進(jìn)行網(wǎng)絡(luò)調(diào)用，并將數(shù)據(jù)保存到數(shù)據(jù)庫(kù)中，但永遠(yuǎn)不會(huì)執(zhí)行，并且沒(méi)有引發(fā)任何錯(cuò)誤。loadFromDb()為什么會(huì)發(fā)生這種情況？ Flowable<Resource<List<List<DataSource>>>> getBoundResource(List<String> parentId) { return new RxNetworkBoundResource<List<List<DataSource>>, ContainerResponse>() { @Override void saveCallResult(@NonNull List<ContainerResponse> data) { for (ContainerResponse item : data) { // Saves data to database List<DataSource> items = item.items; containerDao.insert(items); } } @Override protected Flowable<List<List<DataSource>>> loadFromDb() { return Flowable.just(parentId).flatMapIterable(d -> d) .flatMap(s -> containerDao.loadContainerByParentIdRx(s)) .distinct() .doOnNext(data -> { // I am able to get data here }) .toList() // I'm not able to get data after toList() .toFlowable() .doOnNext(data -> { // Nothing here }); }
1 回答
莫回?zé)o
TA貢獻(xiàn)1865條經(jīng)驗(yàn) 獲得超7個(gè)贊
請(qǐng)注意，僅在其上游完成后才會(huì)發(fā)出。醫(yī)生.toList()
此處的問(wèn)題很可能是由于此代碼返回了 未完成的 ：Flowable
containerDao.loadContainerByParentIdRx(s)
如果這永遠(yuǎn)不會(huì)完成，那么結(jié)果也不會(huì)完成，也不會(huì)發(fā)出任何東西。FlowableflatMaptoList()
如果只查找數(shù)據(jù)庫(kù)一次，則一個(gè)選項(xiàng)是將返回類型更改為 或 。例如，如果切換到 ，則可以執(zhí)行以下操作：SingleMaybeMaybe
@Override
protected Flowable<List<List<DataSource>>> loadFromDb() {
return Flowable.just(parentId).flatMapIterable(d -> d)
.flatMapMaybe(s -> containerDao.loadContainerByParentIdRx(s))
.distinct()
.doOnNext(data -> {
// I am able to get data here
})
.toList() // You should now get this as well.
.toFlowable()
.doOnNext(data -> {
// Nothing here
});
}
添加回答
舉報(bào)
0/150
提交
取消