kotlin-coroutines - Kotlin Flow 内でリストをフィルタリングする方法

Question

RxJavatoCoroutinesとを使用して現在の実装を置き換えていFlowます。一部のFlow演算子の使用に問題があります。

Flow収集するアイテムを提供する前に、アイテムのリストをフィルタリングしようとしています。( Flow<List<TaskWithCategory>>)

の例を次に示しますRx2。

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

上記の実装では、既に完了しているTaskWithCategoryによるフィルタリングのリストを提供しています。Task

を使用してこれを達成するにはどうすればよいFlowですか?