如果Maybe完成,则将Maybe转换为Single来自另一个源

发布时间：2020-12-15 03:06:57 所属栏目：Java 来源：网络整理

导读：我想构建一个返回Single Something的Repository类. 该类应该首先查看Cache,它返回Maybe Something如果Maybe完成,请转到我的服务,返回Single Something interface Cache { fun getSomething(): MaybeSomething }interface Service { fun getSomething(): Sing

我想构建一个返回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()
        }
  }

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!