Всем привет, может кто подсказать следующий момент по корутинам? Если я

Question

Всем привет, может кто подсказать следующий момент по корутинам? Если я

мерджу два флоу и после этого дополнительно у второго флоу делаю tryEmit, мне надо чтобы мердж выше опять сработал, как такое сделать? Вот пример:

val flowA = MutableStateFlow(1)
val flowB = MutableStateFlow(2)

merge(flowA, flowB).collect { println(it) } // Напечатает 1, 2

flowB.tryEmit(3) // merge выше должен напечатать 3

со StateFlow такой трюк не работает, он напечатает 1, 2 и все, 3 не напечатает

#kotlin #programming #russian

0

25.03.2022

8 ответов

31 просмотр

ilya the 大佬 🇹🇼 Автор вопроса

Alexander Nozik
у вас collect - терминирующая операция. После него...

а что вместо collect здесь использовать надо?

0

25.03.2022

Alexander Nozik

ilya the 大佬 🇹🇼
а что вместо collect здесь использовать надо?

Можно сделать onEach{..}.launchIn(...) или завернуть collect в launch, чтобы он выполнялся в другой корутине

0

25.03.2022

ilya the 大佬 🇹🇼 Автор вопроса

Alexander Nozik
Можно сделать onEach{..}.launchIn(...) или заверну...

о, работает так действительно, спасибо. А может еще подскажете, почему в rx observable - flow конвертации сделали ChannelFlow возвращаемым значением, это потому что для маппинга с rx в корутины надо использовать сабжекты чтобы мапить в stateflow/sharedflow, и observable, соответсвенно, мапится в каналы (channelFlow)?

0

25.03.2022

Alexander Nozik

ilya the 大佬 🇹🇼
о, работает так действительно, спасибо. А может ещ...

Тут не подскажу. Но вообще ChannelFlow - это очевидный способ сделать "горчий" поток

0

25.03.2022

ilya the 大佬 🇹🇼 Автор вопроса

Alexander Nozik
Тут не подскажу. Но вообще ChannelFlow - это очеви...

так stateflow/sharedflow тоже горячие же

0

25.03.2022

Alexander Nozik

ilya the 大佬 🇹🇼
так stateflow/sharedflow тоже горячие же

Ну там внутри тоже каналы. Вообще stateFlow появился сильно позже. Возможно интеграция с rx была уже в этот момент

0

25.03.2022

Agry Gami

ilya the 大佬 🇹🇼
так stateflow/sharedflow тоже горячие же

Елизаров писал что sharedflow это эволюция channelflow и лучше использовать sharedflow... я сталкивался с какими-то неочевидными блокировками когда использовал channelflow и после перехода на sharedflow всё стало работать

0

25.03.2022

Alexander Nozik · Accepted Answer

Alexander Nozik

у вас collect - терминирующая операция. После него ничего не может быть. Точнее он засуспендится навечно, пока кто-то не закроет flow

0

25.03.2022

169 похожих чатов

Всем привет, может кто подсказать следующий момент по корутинам? Если я

8 ответов

Похожие вопросы