在RxJava 2中展平列表

Question

我已经使用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

Answer 1

您需要使用,fromIterable()因为任何List<T>扩展Collection<T>延伸Iterable<T>

Observable.fromIterable(list)
          .filter(str -> str.contains("Help")
          .subscribe(...);