【问题标题】:Flatten a list in RxJava 2在 RxJava 2 中展平列表
【发布时间】:2019-04-20 00:37:32
【问题描述】:

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

【问题讨论】:

    标签: java rx-java rx-java2


    【解决方案1】:

    您需要使用fromIterable(),因为任何List&lt;T&gt; 扩展Collection&lt;T&gt; 扩展Iterable&lt;T&gt;

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

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2012-04-25
      • 2015-09-06
      • 1970-01-01
      • 1970-01-01
      • 2012-03-19
      相关资源
      最近更新 更多