首页 文章

在RxJava 2中展平列表

提问于
浏览 次
5

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

1 回答

  • 18

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

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

相关问题