如何将可观察<列表<A>>转换为可流动<A>。Rx 爪哇

Question

我试图转换Observable<列表>至可流动

• RxJava，但是它不起作用。你会给出建议还是解决方案？，谢谢

return  resource.flatMap(
new Function<Observable<List<Product>>, List<Product>>() {
@Override
public List<Product> apply(Observable<List<Product>> products) throws Exception {
return (List<Product>) products;
}
}).toFlowable(BackpressureStrategy.BUFFER)

Answer 1

您需要flatMapIterable:

return resource.flatMapIterable(list -> list)
.toFlowable(BackpressureStrategy.BUFFER)