Kotlin Flow 离线缓存

Question

我是 kotlin flow 的新手，我正在处理这个文档。 Kotlin Flows。在这段代码中，数据源每五秒从 api 获取数据并发出它。

这是我的示例数据源类。

我正在获取数据并发送它。

class RemoteDataSourceImpl @Inject constructor(
private val api:CryptoApi
): RemoteDataSource {


override suspend fun cryptoList(): Flow<List<CryptoCoinDto>> {
    return flow {
        while (true){
            
            val data = api.getCoinList()
            emit(data)
            delay(5000L)
        }
    }
   }
}

这是我的示例存储库。

我正在映射数据并将其保存为房间数据库。由于单一事实来源原则，我想从房间数据库中获取数据并发出它，但我仍然必须返回 dataSource，因为如果我打开新流{}，我无法访问数据源的数据。当然，我可以通过在 RemoteDataSource 类中使用 List 而不是 Flow 来解决问题。但我想了解这个例子。我如何在这里应用单一事实来源。

class CoinRepositoryImpl @Inject constructor(
private val dataSource:RemoteDataSource,
private val dao: CryptoDao
):CoinRepository {

override fun getDataList(): Flow<List<CryptoCoin>> {

     dataSource.cryptoList().map { dtoList ->
        val entityList = dtoList.map { dto ->
            dto.toCryptoEntity()
        }
        dao.insertAll(entityList)
    }
    return dataSource.cryptoList().map {
        it.map { it.toCryptoCoin() }
    }

}

Answer 1

这实际上比看起来更复杂。流程旨在支持背压，这意味着它们通常只在被消费时按需生产项目。它们是被动的，而不是推动物品，而是从流程中拉出物品。

（免责声明：这对于冷流来说都是正确的，而不是热流。但cryptoList() 是冷流。）

这样设计的目的是大大简化消费者比生产者慢或根本没有人消费物品的情况。然后生产者停止生产，一切都很好。

在您的情况下，有两个消费者，所以这又更复杂了。如果一个消费者比另一个消费者慢，你需要决定应该发生什么。例如，如果没有人从getDataList() 收集数据会发生什么？有多种选择，每种方法都需要一些不同的方法：

1. 停止使用源流，因此停止更新数据库。
2. 如果没有人从getDataList() 收集，请始终更新数据库并将项目排队。如果队列中的项目越来越多怎么办？
3. 如果没有人从 getDataList() 收集，请始终更新数据库并丢弃项目。

Ad.1.

可以使用onEach():

return dataSource.cryptoList().onEach {
    // update db
}.map {
    it.map { it.toCryptoCoin() }
}

在此解决方案中，更新数据库是使用 getDataList() 流的“副作用”。

广告 2。和 Ad.3。

在这种情况下，我们不能被动地等到有人向我们索要物品。我们需要主动消费源流中的项目并将它们推送到下游流。所以我们需要一个热流：SharedFlow。此外，因为在这种情况下我们仍然是主动方，所以我们必须启动一个协同程序，它将在后台执行此操作。所以我们需要一个CoroutineScope。

解决方案取决于您的具体需求：您是否需要队列，如果队列超过大小限制会发生什么等，但它类似于：

return dataSource.cryptoList().onEach {
    // update db
}.map {
    it.map { it.toCryptoCoin() }
}.shareIn(scope, SharingStarted.Eagerly)

您还可以阅读 buffer() 和 MutableSharedFlow - 它们可能对您有用。