Me deparei com um exemplo que simula o acesso a um banco de dados lento para obter um fluxo de identificadores de usuários associados a um perfil que pode ser acessado por meio de um recurso de rede ainda mais lento:
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")}
}
}
a emissão dos IDs e a solicitação de perfis estão interligadas. Como eu otimizaria isso gerando novas coroutines para o processamento de cada elemento no fluxo?