从网络和数据库获取请求 rxJava

Question

我会从数据库获取requset，同时从网络获取请求。从网络请求保存在DateBase中，我想但它不能正常工作

fun loadMovie(id: Int): Single<AboutMovie> = database.getMovie(id = id)
        .onErrorResumeNext( aboutMovieService.getMovie(movieId = id) )
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())

Answer 1

我不完全理解您想要实现的目标，但让我为您提供该代码。

fun loadMovie(id: Int): Single<Movie> =
    database.getMovie(id = id) // get cached entry from database
        .onErrorResumeNext { // if any error occured
            getNetworkMovie(id = id) // do network request
                .doOnSuccess { database.saveMovie(movie) } // on network request success save to database
        }