asynchronous - 如何使用协程传递结果？

Question

假设我有仓库列表。我想遍历所有这些。当每个存储库返回结果时，我想将其传递出去。

val repos = listOf(repo1, repo2, repo3)
val deferredItems = mutableListOf<Deferred<List<result>>>()

repos.forEach { repo ->
    deferredItems.add(async { getResult(repo) })
}

val results = mutableListOf<Any>()
deferredItems.forEach { deferredItem ->
    results.add(deferredItem.await())
}

println("results :: $results")

在上述情况下，它等待每个存储库返回结果。它按顺序填充results，先是repo1的结果，然后是repo2的结果。如果 repo1 比 repo2 返回结果的时间更长，我们将等待 repo1 的结果，即使我们有 的结果仓库2。

有没有办法在我们得到结果后立即传递repo2的结果？

Answer 1

Flow API 几乎直接支持这一点:

repos.asFlow()
        .flatMapMerge { flow { emit(getResult(it)) } }
        .collect { println(it) }

flatMapMerge 首先收集来自您传递给它的 lambda 的所有 Flow，然后同时收集这些并将它们发送到一旦其中任何一个完成，就向下游发送。