如何在 Kotlin 中将 Fuel 与协程一起使用？

我想获取 API 请求并将请求的数据保存到数据库。还想返回数据（即写入数据库）。我知道，这在 RxJava 中是可能的，但现在我用 Kotlin 协程编写，目前使用 Fuel 而不是 Retrofit （但差异不是那么大）。我读如何将 Fuel 与 Kotlin 协程一起使用 https://stackoverflow.com/questions/50402433/how-to-use-fuel-with-a-kotlin-coroutine，但不明白。

如何编写协程和方法？

UPDATE

比如说，我们有 Java 和 Retrofit，RxJava。然后我们就可以写代码了。

地区响应：

@AutoValue
public abstract class RegionResponse {
    @SerializedName("id")
    public abstract Integer id;
    @SerializedName("name")
    public abstract String name;
    @SerializedName("countryId")
    public abstract Integer countryId();

    public static RegionResponse create(int id, String name, int countryId) {
        ....
    }
    ...
}

Region:

data class Region(
    val id: Int,
    val name: String,
    val countryId: Int)

Network:

public Single<List<RegionResponse>> getRegions() {
    return api.getRegions();
    // @GET("/regions")
    // Single<List<RegionResponse>> getRegions();
}

区域存储库：

fun getRegion(countryId: Int): Single<Region> {
    val dbSource = db.getRegion(countryId)
    val lazyApiSource = Single.defer { api.regions }
            .flattenAsFlowable { it }
            .map { apiMapper.map(it) }
            .toList()
            .doOnSuccess { db.updateRegions(it) }
            .flattenAsFlowable { it }
            .filter({ it.countryId == countryId })
            .singleOrError()
    return dbSource
            .map { dbMapper.map(it) }
            .switchIfEmpty(lazyApiSource)
}

区域交互器：

class RegionInteractor(
    private val repo: RegionRepository,
    private val prefsRepository: PrefsRepository) {

    fun getRegion(): Single<Region> {
        return Single.fromCallable { prefsRepository.countryId }
                .flatMap { repo.getRegion(it) }
                .subscribeOn(Schedulers.io())
    }
}

我们一层一层看。

首先，你的RegionResponse and Region据我所知，对于这个用例来说完全没问题，所以我们根本不会碰它们。

您的网络层是用 Java 编写的，因此我们假设它始终期望同步行为，并且也不会触及它。

因此，我们从存储库开始：

fun getRegion(countryId: Int) = async {
    val regionFromDb = db.getRegion(countryId)

    if (regionFromDb == null) {
        return apiMapper.map(api.regions).
                  filter({ it.countryId == countryId }).
                  first().
           also {
           db.updateRegions(it)
        }
    }

    return dbMapper.map(regionFromDb)
}

请记住，我没有您的代码，因此细节可能会有所不同。但协程的总体思路是，您可以使用以下命令启动它们async()如果他们需要返回结果，然后编写代码，就好像您处于完美的世界中，无需关心并发性。

现在对于交互者：

class RegionInteractor(
    private val repo: RegionRepository,
    private val prefsRepository: PrefsRepository) {

    fun getRegion() = withContext(Schedulers.io().asCoroutineDispatcher()) {
        val countryId = prefsRepository.countryId
        return repo.getRegion(countryId).await()
    }
}

您需要一些东西来将异步代码转换回同步代码。为此，您需要某种线程池来执行。这里我们使用 Rx 中的线程池，但如果您想使用其他池，也可以这样做。