Описание тега kotlinx.coroutines.flow
0
ответов
Потоки - клонирование потока без многократной итерации - я делаю это правильно?
Я только начинаю знакомиться с потоками Котлина. Для этого я использую их для анализа содержимого двоичного файла, который я буду моделировать с использованием следующего потока: fun testFlow() = flow { println("Starting loop") try { for (i in 0..5)…
22 авг '19 в 20:05
1
ответ
Как я могу отправлять предметы в Kotlin.Flow (например, предмет поведения)
Я хотел знать, как я могу отправлять / отправлять Kotlin.Flow, так что мой вариант использования: В потребительской /ViewModel/Presenter я могу подписаться с collect функция: fun observe() { coroutineScope.launch { // 1. Send event reopsitory.observ…
04 авг '19 в 12:12
3
ответа
Методы тестирования Room DAO с помощью Kotlin Coroutines и Flow
Я пытаюсь перейти с LiveData на Flow в моем Room Dao. Приложение работает нормально, но у меня проблемы с поведением при тестировании. Когда я запускаю тест, он запускается и работает бесконечно. Я также пытался использовать kotlinx.coroutines.test …
28 окт '19 в 13:30
2
ответа
Kotlin Flow против LiveData
Во время последнего ввода-вывода Google Хосе Альсеррека и Йигит Бояр сказали нам, что мы больше не должны использовать LiveData для получения данных. Теперь мы должны использовать функции приостановки для одноразовой выборки и использовать поток Kot…
16 ноя '19 в 14:14
0
ответов
Проблемы с имитацией сопрограмм ProducerScope
У меня есть функция, которая создает channelFlow, а затем передает область в качестве аргумента другому классу. journeyRepository.canGetPagedJourneys(this) У меня проблемы с издевательством над "этим" (ProducerScope) Функция, которую мне нужно проте…
16 дек '19 в 17:41
1
ответ
Как отфильтровать список внутри Kotlin Flow
Я заменяю свою текущую реализацию, используя RxJava к Coroutines а также Flow. У меня проблемы с использованием некоторыхFlow операторы. Я пытаюсь отфильтровать список элементов внутри Flowпрежде чем предоставить его для сбора. (Flow<List<Task…
22 дек '19 в 17:30
2
ответа
Функция приостановки может быть вызвана только в теле сопрограммы
Я пытаюсь обновлять свое представление в реальном времени с помощью Kotlin Flows и Firebase. Вот как я собираю данные в реальном времени из ViewModel: class MainViewModel(repo: IRepo): ViewModel() { val fetchVersionCode = liveData(Dispatchers.IO) { …
24 фев '20 в 22:44
1
ответ
Как отменить / отказаться от подписки на сопрограммы Flow
Я замечаю странное поведение при попытке преждевременно отменить поток. Взгляните на следующий пример. Это простой поток, который выдает целочисленные значения private fun createFlow() = flow { repeat(10000) { emit(it) } } Затем я звоню createFlow ф…
10 янв '20 в 14:11
1
ответ
Как вернуть fusedLocationProviderClient(). LastLocation как поток из функции в сопрограммах kotlin
Что я делаю Поэтому я разрабатываю приложение для прогноза погоды, в котором я получаю доступ к местоположению устройства с помощью fusedLocationProviderClient.lastLocation, и большинство из нас знает, что поставщик местоположения возвращает задачу,…
14 июн '20 в 12:05
1
ответ
Можно ли использовать текст / поток событий с помощью JavaScript в WebBrowser?
У нас есть служба отдыха, которая возвращает text/event-streamиз конечной точки POST, которая содержит серию объектов JSON.(Это Spring Boot / Kotlin RestController, который возвращает kotlinx.coroutines.flow.Flow<SomeJSONObject>Теперь мы хотим…
19 фев '21 в 18:26
3
ответа
Как заменить LiveData на Flow
Есть один LiveData с именем, а затем у меня есть еще одна переменная с именем myData что замечает любые изменения в sortOrder и соответственно заполняет данные. class TestViewModel @ViewModelInject constructor() : ViewModel() { private val sortOrder…
09 янв '21 в 17:11
2
ответа
SharedFlow: mapLatest не запускается
Давайте сделаем это просто. У меня есть одно имя в моем. private val sortOrder = MutableSharedFlow<String>( replay = 0, extraBufferCapacity = 1 ) Я подключен к, чтобы обновлять данные всякий раз, когда они меняются. val data = sortOrder.mapLat…
08 янв '21 в 20:00
1
ответ
Как отменить сбор сопрограммы StateFlow?
Я собираю поток из общей модели просмотра во фрагменте: private val viewModel: MyViewModel by sharedViewModel() private fun observeViewModelStateFlowData() { job = lifecycleScope.launch { viewModel.stateFlowData.collect { when (it) { is ViewStates.S…
27 июл '21 в 19:26
1
ответ
Проблема с новой версией kotlinx-coroutines-play-services в моем коде
Я уже добавил сервисы воспроизведения сопрограмм в свой код, все работало, найти, но после обновления сопрограмм до версии 1.3.2 мое приложение вылетало и вызывало ошибку, указанную ниже, но в трассировке стека невозможно увидеть происхождение ошибк…
04 авг '21 в 12:30
0
ответов
Как снова запустить (Flow of PagingData), если вначале нет интернета
Я пытаюсь сделать приложение с бесплатными ошибками, но замечаю, что Поток <PagingData> если я попаду в него в первый раз без интернета, я не смогу попасть в него снова. Итак, мой вопрос в том, как повторно попасть в поток в любое время, когда…
07 окт '21 в 10:27
3
ответа
Как создать обратный отсчет с помощью сопрограмм потока
Я пытаюсь создать поток с сопрограммами, но это не дает мне ожидаемого результата. Я бы хотел указать время истечения срока действия (неважно, в миллисекундах, секундах и т. Д.), Когда время достигает 0, обратный отсчет останавливается. Что у меня с…
18 ноя '21 в 13:57
1
ответ
Почему AsyncPagingDataDiffer submitData() должен замораживать и отключать тест?
Я пытаюсь следовать этой документации, касающейся того, как проводить модульное тестирование потока PagingData, к которому вы применяете преобразования. Код, который я использую, похож: @ExperimentalCoroutinesApi @Test fun testGetFooBarsPaged(): Uni…
02 дек '21 в 21:44
0
ответов
Как проверить комбинированный StateFlow холодного и горячего потока?
У меня есть ViewModel, который наблюдает за холодным потоком из источника данных. В то же время View отправляет некоторый ввод через MutableStateFlow. Я хочу объединить эти два, чтобы реагировать на изменения данных и ввод в одном потоке. Я использу…
09 дек '21 в 14:54
1
ответ
Перемещение окна с помощью Kotlin Flow
Я пытаюсь создать движущееся окно данных с помощью Kotlin Flows. Это может быть достигнуто в RxKotlin с использованием буфера, но буфер - это не то же самое, что и с использованием потоков. У RxKotlin есть оператор, который периодически собирает эле…
12 дек '21 в 23:13
1
ответ
Доступ к значениям за пределами области сопрограммы в Kotlin
Я получил этот код прямо здесь, он отлично работает. Я могу распечатать значения, которые получаю от каждого задания / сопрограмм, запускаемых в области видимости. Но проблема в том, что мне сложно использовать значения за пределами области видимост…
22 дек '21 в 20:30