在 RxJava 2 中展平列表 [英] Flatten a list in RxJava 2

问题描述

我已经使用 RxJava 1 一段时间了，但我想看看 RxJava 2.在 RxJava 1 中，我可以按如下方式发出列表的每个项目:

I have been using RxJava 1 for some time but I want to look at RxJava 2. In RxJava 1, I could emit each item of list as follows:

List<String> list = ...
Observable.from(list)
    .filter(str -> str.contains("Help")
    .subscribe(...);

但是，我如何使用 RxJava2 实现相同的目标?我尝试使用以下内容，但似乎无法通过以下内容:

However, how can I achieve the same with RxJava2? I have tried to use the following but I can't seem to get past the following:

Observable.fromArray(list)
// this now passes a list into the stream - there is no Observable::from

推荐答案

你需要使用 fromIterable() 因为任何 List 扩展 Collection<;T> 扩展了 Iterable

You need to use fromIterable() since any List<T> extends Collection<T> which extends Iterable<T>

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

这篇关于在 RxJava 2 中展平列表的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！