我使用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
发布于 2017-01-08 20:06:20
您需要使用fromIterable()
,因为任何List<T>
都会扩展扩展Iterable<T>
的Collection<T>
Observable.fromIterable(list)
.filter(str -> str.contains("Help")
.subscribe(...);
https://stackoverflow.com/questions/41537071
复制相似问题