java - 在 RxJava 中将 Observable<List<Car>> 转换为 Observable<Car> 序列

标签 java reactive-programming rx-java

给定汽车列表 (List<Car> cars),我可以:

Observable.just(cars); //returns an Observable that emits one List<Car>
Observable.from(cars); //returns an Observable that emits a squence of Car

我有什么办法可以从 ObservableList<Car>Observable<Car> 的序列?

类似于 from无参数

Obserable.just(cars).from()

最佳答案

您可以映射 Observable<List<Car>>Observable<Car>像这样:

yourListObservable.flatMapIterable(x -> x)

请注意,flatMapping 可能不会保留源 observable 的顺序。如果订单对您很重要,请使用 concatMapIterable .阅读 here了解更多详情。

关于java - 在 RxJava 中将 Observable<List<Car>> 转换为 Observable<Car> 序列,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/29672705/

相关文章:

retrofit - 将 RxJava observable 的错误转换为另一个 observable 并吞下成功

multithreading - 如何将 Retrofit 2 与 Realm 和 RxJava 结合起来

rx-java - 并行数据库搜索的 Schedulers.io()

java - Spring Boot 将 'es' 添加到链接

java.util.Date - 测试转换美国 <-> 英国

java - 多线程环境中的 log4j。每个线程一个 Appender 或者每个线程一个 Logger 或者...?

system.reactive - subscribeOn 和 observeOn 应该只由最终订阅者调用吗?

postgresql - 与 postgreSQL 而不是 MongoDB 的 meteor react

Java 7 泛型类型推断失败

toString() 的 Java 值不打印