flatMapPublisher
的目的是什么?return factory.retrieveDiskDataStore().isCached()
.flatMapPublisher {
factory.retrieveDataStore(it).getData(token)
}
.flatMap {
Flowable.just(if (it is PickupListDataModel) mapper.mapFromData(it) else null)
}
.flatMap {
saveData(it).toSingle { it }.toFlowable()
}
在这段代码中,factory.retrieveDiskDataStore().isCached()
检查信息是否存储在数据库中。
如果没有,则执行以下代码
.flatMapPublisher {
factory.retrieveDataStore(it).getData(token)
}