遇到了一个例子,模拟访问一个慢速数据库以获取与可通过更慢的网络资源访问的配置文件相关联的用户标识符流:
fun getAllUserIds():Flow<Int>{
return flow{
repeat(3){
delay(200.milliseconds)
log("Emitting!")
emit(it)
}
}
}
suspend fun getProfileFromNetwork(id:Int):String{
delay(2.seconds)
return "Profile[$id]"
}
fun main(){
val ids = getAllUserIds()
runBlocking{
ids
.map{getProfileFromNetwork(it)}
.collect{log("Got $it")}
}
}
ID 的发布和配置文件的请求是相互交织的。我该如何通过为流程中的每个元素的处理生成新的协程来优化这一点?