如何发出错误，然后使用RxJava发出缓存数据？

Question

我正在MVP解决方案中使用RxJava，我希望实现以下场景：

>

如果由于任何原因不成功（没有互联网-服务器无法访问-服务器内部错误）显示适当的消息，但也使用缓存的数据填充视图。

制约因素：

>

我不想使用任何额外的回调（RX可以做到这一切）

我不想直接从演示者访问本地回购

我尝试的内容：

在我的回购中：

    override fun getRepos(userName: String, page: Int, pageSize: Int):Observable<List<Repo>> {

 return githubRemoteService.getReposList(userName, page, pageSize)
                .subscribeOn(schedulersProvider.ioThread())
                .flatMap { repos ->
                    val mappedRepos = remoteResponseMapper.mapRepoResponse(repos)
                    githubLocalService.saveRepos(mappedRepos)
                    Observable.just(mappedRepos)
                }
 .onErrorResumeNext(Observable.just(githubLocalService.getReposList(userName, page, pageSize)))
               .observeOn(schedulersProvider.mainThread())

    }

在我的演讲者：

githubInteractor.getRepos(userName, page, pageSize).subscribe(
            { repos ->
                 showReposInView(repos)
            },
            { error ->
                digestAndShowErrorInView(error)  //the problem is here - no error will be present here
            })

正如我们所知，当我使用onErrorResumeNext时，可观察的源会发生变化，但永远不会发出错误。

如何先发出错误，然后再发出本地回购数据？

如果不能这样做，我如何更改方案以获得相同的方案？

Answer 1

您不能使用OneError继续流<“代码>onError”表示发生了严重错误，可观察到的错误结束。你不能用它。

有一个简单的解决方案。您可以将结果包装在指示错误/数据的结构中。例如。

sealed class MyData
data class Success(val data: List<Repo>) : MyData
data class Error(val t: Throwable): MyData

您可以将成功的API响应映射到成功，如果出现错误（在onErrorResumeNext中），您可以创建Error类并使用concat继续使用本地存储库列表。

这样，您可以在onNext中获得错误和成功，并且不会打破链条。

在onNext中，您可以在时使用并适当地处理错误/成功。