Вопросы по теме 'kotlin-coroutines-flow'

Сначала подождите, затем обработайте остальные в фоновом режиме
У меня есть поток чего-то. И мне нужно написать функцию, которая как можно скорее возвращает первый элемент, а все последующие вызовы этих функций возвращают последнее значение потока. val f = flow { emit(1) delay(100) emit(2) }...
351 просмотров

Почему поток, созданный на ConflatedBroadcastChannel, может получать только последний элемент?
Следующий код печатает только 10000, то есть только последний элемент val channel = BroadcastChannel<Int>(Channel.CONFLATED) val flowJob = channel.asFlow().buffer(Channel.UNLIMITED).onEach { println(it) }.launchIn(GlobalScope) for (i in...
221 просмотров

Сохранение удаленных данных отдельно связанных таблиц при использовании NetworkBoundRepository с сопрограммами (android)
Я хочу использовать в своем приложении принцип единого источника истины. Как добавить несколько таблиц при использовании NetworkBoundRepository. MainApi.kt interface MainApi { @GET("main") suspend fun getMain():...
102 просмотров

Android Test Room + Paging 3 + Flow test дает разные результаты при каждом запуске
Страница 3, с номером. Я создал приложение, подобное приведенному в примере здесь , и запускаю написание теста для него. Вот что у меня есть в DAO: @Query("SELECT * FROM Model") fun getModels(): PagingSource<Int, Model>...
47 просмотров