java – 如何合并flatMapIterable中的项目

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了java – 如何合并flatMapIterable中的项目，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含791字，纯文字阅读大概需要2分钟。

内容图文

我有一个无限的可观察(db观察者),它发出有限的项目序列,需要处理然后作为一组发回.

这里的问题是,如何编写它以便toList不等待原始源完成,而是替换flatMapIterable生成的序列;

DbObservable.map(new Func1<Query, List<Item>>() {
                        @Override
                        public List<Item> call(Query query) {
                            return query.items; //get items from db query
                        }
                    })
                    .flatMapIterable(new Func1<List<Item>, Iterable<Item>>() {
                        @Override
                        public Iterable<Item> call(List<GeoStop> geoStops) {
                            return geoStops;
                        }
                    })
                    .flatMap(/*process*/)
                    .toList() // regenerate List that was passed in to flatMapIterable
                    //subscribe and emit list of items

由于toList被卡住等待DbObservable的onComplete,没有任何东西到达订阅者.

解决方法:

您可以使用flatMap toList处理第一个flatMap内的List：

db.map(q -> q.items)
  .flatMap(items -> Observable.from(items).flatMap(...).toList())
  .subscribe(...)

内容总结

以上是互联网集市为您收集整理的java – 如何合并flatMapIterable中的项目全部内容，希望文章能够帮你解决java – 如何合并flatMapIterable中的项目所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端