Kotlin Flows 地图

Question

我有一个关于 kotlin 流合并的问题。看看下面的乐趣。

suspend fun method(filter: String): Flow<List<Model>> {

// Search.
val models: List<Model> = repo.getModels(filter)  // suspend function

// Get favorites
val favoritesFlow: Flow<List<Int>> = otherRepo.getFavorites()

// Return models as Flow, but mark/unmark every model as favorite when favoritesFlow is updated.
??? val result = models + favoritesFlow ????

    return result
}

我需要返回模型列表流，但是当最喜欢的流更改时，我必须将每个模型标记或取消标记为最喜欢的。你知道我该怎么做吗？

Answer 1

您可以使用 Flow.combine() 组合两个流的发出值

fun favoriteModels() : Flow<List<Model>> = repo.getModels(filter)
    .combine(otherRepo.getFavorites()) { models, favorites ->
        models.filter { model -> favorites.contains(model.id) }
    }