如何在RxJava中实现可完成性与单件性的结合

Question

我正在构建一个应用程序，从互联网缓存数据，当手机脱机时，它将显示脱机项目（该功能按预期工作）。现在我很难包含一个刷新选项（我基本上会删除缓存中的项，并尝试获取更多最近的项）。我有两个问题：

1. 我不知道如何将Completable和Single结合起来，它给了我一个错误，下面的函数都不能用提供的参数调用
2. 我不知道如何将参数传递给andThen运算符中的函数getWeather。

fun deleteWeatherForecast(lat : Double, lng: Double) : Completable
{
    return lWeatherRepo.deleteWeatherForecast(lat,lng)
            .andThen(rWeatherRepo::getWeather(lat,lng))
        .subscribeOn(Schedulers.io())
}

fun deleteWeatherForecast(lat: Double, lng: Double) : Completable
{
    return weatherDao.deleteForecastByLocation(lat,lng)
}

RemoteWeatherRepository

fun getWeather(lat: Double, lng: Double): Single<Weather> {
    val locationStr = String.format("%f,%f",lat,lng)
    return weatherService.getWeatherForecastResponse(API_KEY,locationStr)
}

我选择Completable是因为我想等到删除完成后再获取下一个

Answer 1

您可以像这样重写天气存储库

fun deleteWeatherForecast(lat : Double, lng: Double) : Completable
{
    return lWeatherRepo.deleteWeatherForecast(lat,lng)
            .andThen(rWeatherRepo.getWeather(lat,lng))  // answer question 2
            .ignoreElement() // answer question 1, convert single to completable
        .subscribeOn(Schedulers.io())
}