使用zip
或combine
,如果我不错过任何东西,就只能合并2个流,我无法看到任何组合流列表或vararg
的公共方法。
例如
apiHelper.getUsers()
.zip(apiHelper.getMoreUsers()) { usersFromApi, moreUsersFromApi ->
val allUsersFromApi = mutableListOf<ApiUser>()
allUsersFromApi.addAll(usersFromApi)
allUsersFromApi.addAll(moreUsersFromApi)
return@zip allUsersFromApi
}
我需要从REST API中获取前5个页面,并并行获取它们,然后合并结果,进行一些Map,并对组合数据进行过滤。我可以使用flow
组合它们吗?或者我应该传递coroutineScope并使用异步来进行并行请求?
我 checkout 了answer here,但它返回了编译错误,并且似乎没有将list作为参数的flow的公共合并函数。
1条答案
按热度按时间omqzjyyz1#
存在顶级
combine
函数