Filtering data using RXJava2 Flowable

Question

I am using Room and RxJava and I would like to use the power of the second to filter data coming from the first.

Let's say room is returning Users.

Flowable<List<User> getUsers()

Then I wanted to filter users by age > 18 for example, so I performed the following :

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

Unfortunately this is not working. My guess is that toList() is never finishing since onTerminated is never called by room. So my question is : what am I doing wrong ? How can I filter my users and still have a Flowable at the end ?

Thanks

Apply toList within the flatMap lambda just after filter. Afaik Room never completes a flow and toList mandates finite source. The inner flow you filter constitutes as finite. — akarnokd
Yes it was that easy. Room is never sending any onComplete but the Flowable build using fromIterable will. Thank you — Mathieu H.

Mathieu H. Mathieu H. · Accepted Answer · 2017-11-13T09:20:27

Room will never call onComplete (and then the toList will never finish) but the inner flow built using fromIterable is finite and will trigger onComplete. So the toList and toFlowable should be called on the flow inside the flatMap

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

Filtering data using RXJava2 Flowable

1 Answers