我正在使用 Room 和 RxJava，我想使用第二个的强大功能来过滤来自第一个的数据。
假设房间正在返回用户。
Flowable<List<User> getUsers()
例如，我想按年龄 > 18 过滤用户，所以我执行了以下操作:
userDao.getUsers()
.flatMap(listUser -> Flowable.fromIterable(listUser).filter(user -> user.age > 18))
.toList()
.toFlowable()
不幸的是，这不起作用。 我的猜测是 toList() 永远不会结束，因为 onTerminated 永远不会被房间调用。 所以我的问题是:我做错了什么？我怎样才能过滤我的用户并在最后仍然有一个 Flowable？
谢谢
最佳答案
Room 永远不会调用 onComplete(然后 toList 永远不会完成)但是使用 fromIterable 构建的内部流程是有限的并且会触发 onComplete。所以应该在 flatMap 内的流上调用 toList 和 toFlowable
userDao.getUsers()
.flatMap(listUser -> Flowable.fromIterable(listUser).filter(user -> user.age > 18).toList().toFlowable())
关于android - 使用 RXJava2 Flowable 过滤数据，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/47226561/