链接 N 个依赖的 observables

Question

我是响应式编程的新手，我已经向自己介绍了 Android 中的 RxJava2。目前，我遇到了一些简单的问题，例如压缩 observables。但是现在，出现了一些新的东西，我试图解释一下。

假设我有一个请求列表Observable<List<Request>>。我想要做的是调用一个 Web 服务，它根据每个请求返回路由列表（包装在 Observable 中）。我已经检查过this 之类的问题，但在这种情况下，我认为我无法对可观察对象和可观察对象列表进行平面映射。

我该怎么做？还有其他运营商吗？

Answer 1

您可以使用flatMapIterable 将Observable<List<Request>> 展平为Observable<Request>。假设您有一个带有签名 Observable<List<Route>> getListOfRoutes(Request request) { ... } 的辅助方法，您可以这样做：

Observable<List<Request>> obs = ...;
obs.flatMapIterable(l -> l)
   .flatMap(request -> getListOfRoutes(request)
       .doOnNext(routes -> request.setRoutes(routes))
       .map(ign -> request)
   )
   ...

这是假设您最终希望将Observable<Request> 发送到下游。如果你想要不同的类型，你可以在 map 运算符中做一些不同的事情来满足你的需要。