我已经使用 RxJava 1 一段时间了,但我想看看 RxJava 2。在 RxJava 1 中,我可以发出列表中的每个项目,如下所示:
List<String> list = ...
Observable.from(list)
.filter(str -> str.contains("Help")
.subscribe(...);
但是,如何使用 RxJava2 实现同样的效果呢?我尝试使用以下内容,但似乎无法超越以下内容:
Observable.fromArray(list)
// this now passes a list into the stream - there is no Observable::from
你需要使用fromIterable()
因为任何List<T>
延伸Collection<T>
这延伸了Iterable<T>
Observable.fromIterable(list)
.filter(str -> str.contains("Help")
.subscribe(...);
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)