我想构建一个返回Single< Something>的Repository类.
该类应该首先查看Cache,它返回Maybe< Something>如果Maybe完成,请转到我的服务,返回Single< Something>
interface Cache {
fun getSomething(): Maybe<Something>
}
interface Service {
fun getSomething(): Single<Something>
}
class Repository (
private val cache: Cache,private val service: Service
) {
fun getSomething(): Single<Something> {
return cache.getSomething()
.????(Feed.getSomething()) //onCompleteTransformToSingle() or similar
}
}
我已经搜索了JavaDoc,但似乎并不存在针对此场景的转换器.
有一个很好的处理方式吗？
解决方法
以下是您可以使用的两个相当简单的选项.第一个我发现更明确.第二个好处是您将在缓存中的任何错误上调用网络.
假设从缓存返回Maybe.例如,如果在缓存中找不到值,则返回Maybe.empty()
1)如果流中有空,switchIfEmpty()将使用调用网络的备用observable.如果流中没有空,则永远不会调用网络.
override fun getSomething(): Single<Something> {
return cache.getSomething()
.switchIfEmpty(
Maybe.defer {
Feed.getSomething().toMaybe()
}
)
.toSingle()
}
2)当转换为单个()时,空可能会返回错误,从而触发网络调用.
override fun getSomething(): Single<Something> {
return cache.getSomething()
.toSingle()
.onErrorResumeNext {
Feed.getSomething()
}
}
