Jgafner
01/28/2021, 7:34 AMvineethraj49
01/28/2021, 7:57 AMmakeManyRequests(list: List<R>) {
list.map { r -> makeOneRequest(r) }.flatten()
}
// this is unbounded concurrency, do not do this ._.
suspend fun coMakeManyRequests(list: List<R>) = coroutineScope {
list.map { r -> async { makeOneRequest(r) } }.awaitAll().flatten()
}
?Timo Gruen
01/28/2021, 8:54 AMrequestList
.parallelStream()
.map { request -> client.execute(request) }
.toList()
louiscad
01/28/2021, 2:47 PMTimo Gruen
01/28/2021, 2:53 PMlouiscad
01/28/2021, 2:56 PMJgafner
01/28/2021, 3:49 PM