Карта Kotlin Flows

У меня проблема с объединением потока котлина. См. Ниже веселье.

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
}

Мне нужно вернуть поток списка моделей, но при изменении потока избранного я должен отметить или снять каждую модель как избранную. Ты хоть представляешь, как я могу это сделать?


android kotlin kotlin-flow coroutine
person Cosmin Mihu    schedule 12.08.2020    source источник
comment
Что вы имеете в виду, отмечая модель как понравившуюся? Вы хотите поменять недвижимость? И внутри комментария вы сказали, измените каждую модель, в то время как в сообщении вы упомянули каждую модель, вы хотите выполнить действие с целыми числами (как индексом моделей), поступающими из потока?   -  person Animesh Sahu    schedule 12.08.2020

Ответы (1)


arrow_upward
1
arrow_downward

Вы можете комбинировать передаваемые значения из обоих потоков с помощью Flow.combine ()

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