我正在使用RxJava
toCoroutines
和替换我当前的实现Flow
。我在使用某些Flow
运算符时遇到了一些麻烦。
我正在尝试Flow
在提供要收集的内容之前过滤 a 中的项目列表。( Flow<List<TaskWithCategory>>
)
这是关于Rx2
:
repository.findAllTasksWithCategory()
.flatMap {
Flowable.fromIterable(it)
.filter { item -> item.task.completed }
.toList()
.toFlowable()
在上面的实现中,我提供了一个已经完成的TaskWithCategory
过滤列表。Task
我怎样才能做到这一点Flow
?