android - 使用 RXJava2 Flowable 过滤数据

Question

我正在使用 Room 和 RxJava，我想使用第二个的强大功能来过滤来自第一个的数据。

假设房间正在返回用户。

Flowable<List<User> getUsers()

例如，我想按年龄 > 18 过滤用户，所以我执行了以下操作:

userDao.getUsers()
.flatMap(listUser -> Flowable.fromIterable(listUser).filter(user -> user.age > 18))
.toList()
.toFlowable()

不幸的是，这不起作用。我的猜测是 toList() 永远不会结束，因为 onTerminated 永远不会被房间调用。所以我的问题是:我做错了什么？我怎样才能过滤我的用户并在最后仍然有一个 Flowable？

谢谢

Answer 1

Room 永远不会调用 onComplete(然后 toList 永远不会完成)但是使用 fromIterable 构建的内部流程是有限的并且会触发 onComplete。所以应该在 flatMap 内的流上调用 toList 和 toFlowable

userDao.getUsers()
.flatMap(listUser -> Flowable.fromIterable(listUser).filter(user -> user.age > 18).toList().toFlowable())