2015-07-03 48 views
1

我有一个List数据模型,User在下面的例子中,从webService(改造)返回。我将List分解为元素并逐一发出,以filter的方式排列。然后,我需要将所有过滤的User s合并,并创建List。请查看下面的代码,以便更清楚。如何将一组Obserbles组合成一个Observable?

webService.getUsers() // returns Observable<List<User>> 
     .subscribeOn(Schedulers.io()) 
     .observeOn(AndroidSchedulers.mainThread()) 
     .flatMap(users -> Observable.from(users)) // split the collection of Users, so we can filter them next step 
     .filter(user -> user.getId() % 2 == 0) // get only Users with even id 
     // How to transform from here to have a List<User> ? 

回答

5

您可以简单地使用RxJava toList()运营商的运营商filter()后。