kotlin-coroutines - 如何在 Kotlin Flow 中过滤列表

Question

我正在使用 RxJava 到 Coroutines 和 Flow 替换我当前的实现。我在使用一些 Flow 运算符时遇到了一些麻烦。

我正在尝试过滤 Flow 中的项目列表，然后再提供它以供收集。 ( Flow<List<TaskWithCategory>> )

这是 Rx2 上的示例:

        repository.findAllTasksWithCategory()
            .flatMap {
                Flowable.fromIterable(it)
                    .filter { item -> item.task.completed }
                    .toList()
                    .toFlowable()

在上面的实现中，我提供了一个由 TaskWithCategory 过滤的 Task 列表，这些过滤已经完成。

如何使用 Flow 实现这一点？

Answer 1

鉴于使用的唯一运算符是 filter，内部流动是不必要的，这使得流程实现非常简单:

repository.findAllTasksWithCategoryFlow()
    .map { it.filter { item -> item.task.completed } }

如果更多地涉及内部转换(让我们使用 transform: suspend (X) -> TaskWithCategory ):

repository.findAllTasksWithCategoryFlow()
    // Pick according to desired backpressure behavior
    .flatMap(Latest/Concat/Merge) {
        // Scope all transformations together
        coroutineScope {
            it.map { item ->
                // Perform transform in parallel
                async {
                    transform(item)
                }
            }.awaitAll() // Return when all async are finished.
        }
    }