如何解决从多个状态流中收集
我的 viewmodel 中有 2 个 stateFlow。要在片段中收集它们,我必须启动协程 2 次,如下所示:
lifecycleScope.launchWhenStarted {
stocksVM.quotes.collect {
if (it is Resource.Success) {
it.data?.let { list ->
quoteAdapter.submitData(list)
}
}
}
}
lifecycleScope.launchWhenStarted {
stocksVM.stockUpdate.collect {
log(it.data?.data.toString())
}
}
如果我有更多的 stateFlow,我必须分别启动协程。有没有更好的方法来处理我的 Fragment/Activity 或其他任何地方的多个 stateFlow?
解决方法
您将需要不同的协程,因为 collect()
是一个挂起函数,它会挂起直到您的 Flow
终止。
对于收集多个流,目前推荐的方法是:
lifecycleScope.launch {
lifecycle.repeatOnLifecycle(Lifecycle.State.STARTED) {
launch {
stocksVM.quotes.collect { ... }
}
launch {
stocksVM.stockUpdate.collect { ... }
}
}
}
请注意,launchWhenStarted
的问题在于,虽然您新发出的项目不会被处理,但您的生产者仍会在后台运行。
我肯定会读一读,因为它很好地解释了当前的最佳实践:https://medium.com/androiddevelopers/a-safer-way-to-collect-flows-from-android-uis-23080b1f8bda
,您可以选择混合多个流。
在merge
中使用函数combine
或kotlin
。当然,这两个函数的用法是不同的。
添加:
如果没有处理Flow,打开多个Coroutines to collect():
fun main() {
collectFlow()
}
fun emitStringElem(): Flow<String> = flow {
repeat(5) {
delay(10)
emit("elem_$it")
}
}
fun emitIntElem(): Flow<Int> = flow {
repeat(10) {
delay(10)
emit(it)
}
}
打开两个协程集合 结果是:
From int Flow: item is: 0
From string Flow: item is: elem_0
From int Flow: item is: 1
From string Flow: item is: elem_1
From int Flow: item is: 2
From string Flow: item is: elem_2
From int Flow: item is: 3
From string Flow: item is: elem_3
From int Flow: item is: 4
From string Flow: item is: elem_4
From int Flow: item is: 5
From int Flow: item is: 6
From int Flow: item is: 7
From int Flow: item is: 8
From int Flow: item is: 9
合并两个流
fun margeFlow() = runBlocking {
merge(
emitIntElem().map {
it.toString()
},emitStringElem()
).collect {
println(it)
}
}
结果是:
0
elem_0
1
elem_1
2
elem_2
3
elem_3
4
elem_4
5
6
7
8
9
合并两个流:
fun combineFlow() = runBlocking {
combine(emitIntElem(),emitStringElem()) { int: Int,str: String ->
"$int combine $str"
}.collect {
println(it)
}
}
结果是:
0 combine elem_0
1 combine elem_0
1 combine elem_1
2 combine elem_2
3 combine elem_3
4 combine elem_4
5 combine elem_4
6 combine elem_4
7 combine elem_4
8 combine elem_4
9 combine elem_4
,
就像@RóbertNagy 所说的,你不应该使用 launchWhenStarted
。但是有一种替代语法可以以正确的方式执行此操作而无需执行嵌套的 launch
es:
stocksVM.quotes
.flowOnLifecycle(Lifecycle.State.STARTED)
.onEach {
if (it is Resource.Success) {
it.data?.let { list ->
quoteAdapter.submitData(list)
}
}
}.launchIn(lifecycleScope)
stocksVM.stockUpdate
.flowOnLifecycle(Lifecycle.State.STARTED)
.onEach {
log(it.data?.data.toString())
}.launchIn(lifecycleScope)
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。