Сбор потоков во ViewModel

Общая идея состоит в том, чтобы просто преобразовать потоки в модели представления, сбор должен выполняться только в пользовательском интерфейсе. Таким образом, пользовательский интерфейс может подписываться и отписываться от потоков по мере необходимости, что экономит ресурсы.

В вашем примере uiState должен быть поток, а именно StateFlow:

val uiState: StateFlow<MyUiState> = transformedFlow(movieId)
    .stateIn(
        scope = viewModelScope,
        started = SharingStarted.WhileSubscribed(5_000),
        initialValue = MyUiState(),
    )

Kotlin StateFlow концептуально похож на Compose State тем, что представляет одно значение, изменения которого можно наблюдать. В ваших составных объектах вы можете получить uiState следующим образом:

val uiState: MyUiState by viewModel.uiState.collectAsStateWithLifecycle()

Для этого вам нужно добавить зависимость androidx.lifecycle:lifecycle-runtime-compose к вашим файлам Gradle. Дополнительную информацию см. https://medium.com/androiddevelopers/sumption-flows-safely-in-jetpack-compose-cde014d0d5a3.

transformedFlow будет объединенным потоком из вашего репозитория:

private fun transformedFlow(movieId: Int) = combine(
    myRepo.getMovie(movieId).filterNotNull(),
    myRepo.getActors(movieId),
) { movie, actors ->
    MyUiState(
        movie = movie,
        actorList = actors,
    )
}

В ответ на комментарий: все, от чего зависит ваш uiState, должно быть предоставлено как поток и объединено с другими потоками. Таким образом, всякий раз, когда что-либо меняется, полученный StateFlow всегда будет актуальным.

В качестве примера того, как это можно сделать, предположим, что ваш MovieId может меняться со временем. Как и сейчас, transformedFlow(movieId) вызывается только один раз при инициализации модели представления. Изменения в movieId не приведут к повторному выполнению getMovie или getActors. Теперь рассмотрите возможность добавления этого в вашу модель представления:

private val selectedMovieId: MutableStateFlow<Int?> = MutableStateFlow(null)

fun selectMovie(movieId: Int) {
    selectedMovieId.value = movieId
}

Теперь идентификатор фильма сам по себе является потоком, и его можно изменить, вызвав selectMovie. Тогда ваш uiState может основываться на этом потоке следующим образом:

@OptIn(ExperimentalCoroutinesApi::class)
val uiState: StateFlow<MyUiState> = selectedMovieId
    .flatMapLatest(::uiStateFlowOf)
    .stateIn(
        scope = viewModelScope,
        started = SharingStarted.WhileSubscribed(5_000),
        initialValue = MyUiState(),
    )

private fun uiStateFlowOf(movieId: Int?): Flow<MyUiState> =
    if (movieId == null)
        flowOf(MyUiState())
    else
        combine(
            myRepo.getMovie(movieId).filterNotNull(),
            myRepo.getActors(movieId),
        ) { movie, actors ->
            MyUiState(
                movie = movie,
                actorList = actors,
            )
        }

Если есть другие источники данных, их потоки необходимо объединить с другими потоками. Если они зависят от идентификатора фильма, просто добавьте их к существующему combine, если они чем-то другим, полностью объедините их с результирующим потоком. stateIn всегда идет последним, объединение необходимо выполнить заранее. Обязательно вынесите логику преобразования в отдельные функции, иначе будет очень сложно понять, что происходит. В конце концов, вся логика трансформации коренится в объявлении uiState и носит функциональный, а не императивный характер. Там можно было бы разместить всё в одном монолитном заявлении. Не делайте этого, вместо этого выделите независимую логику в отдельные функции.

Если ваши источники данных не предоставляют потоки, их, вероятно, можно легко обернуть потоками: см. https://developer.android.com/kotlin/flow, особенно раздел о callbackFlow. Если вы все еще где-то используете LiveData, есть удобный asFlow() метод для преобразования их в потоки.