Jersey RxJava客户端和资源endpoint集合

Question

我对RxJava非常陌生，我仍在尝试理解数据流，但我想知道这是否可能，然后再深入兔子洞。

目标：解耦API资源并允许其分布，同时为客户端（web/移动）提供灵活性，以便根据仅提供给少数“已知”APIendpoint的href链接获取数据。

我从一个API中收集了JSON对象，其中每个json都有一个“href”字段，该字段提供指向API资源的链接，可以在其中检索数据的全部详细信息。例如：

{
   {
      name: "assassins_creed",
      href: "games/assassins_creedId123"
   },
   {
      name: "bioshock",
      href: "games/bioshockId456"
   },
   {
      name: "clean_code",
      href: "books/clean_codeId789"
   },
   {
      name: "christmas",
      href: "events/xmas001"
   }
}

检索此集合后，我想使用该href值调用相应的资源，并将结果存储在一个集合中，如JSON数组。

我将JSON对象列表中的字符串映射到另一个列表中，然后尝试将它们添加到一个可观察对象中，以便可以将每个资源异步检索到相同的响应中。

我一直在使用Jersey示例作为参考，我担心它无法获取动态href链接并返回我想要的响应。

到目前为止，我停留在：

@Override
public List<JSONObject> getUsersDashboard(TokenModel token, String userId, @Suspended final AsyncResponse async) {
    List<JSONObject> list = //Database request to get items for userId
    List<String> hrefLinks = list.stream()
            .map(e -> (String) e.get("href"))
            .collect(Collectors.toList());

    final Queue<String> errors = new ConcurrentLinkedQueue<>();

    Observable.just(new JSONArray())
            .zipWith(dashboard(token.getAccessToken(),"plhUrl", errors), (array, objects) -> {
                array.add(objects);
                return array;
            })
            .subscribe(response -> {
                //errors?
                async.resume(response);
            }, async::resume);
}

private Observable<List<JSONObject>> dashboard(String access, String urlFragment, Queue<String> errors) {
     Client client = ClientBuilder.newClient();
     return RxObservable.from(client).target(urlFragment).request()
            .header("Authorization", access)
            .rx()
            .get(new GenericType<List<JSONObject>>(){})
            .onErrorReturn(throwable -> {
                errors.offer(throwable.getMessage());
                return Collections.emptyList();
            });
}

我很犹豫是否将其放入for循环中，以便为每个hreflings条目创建可观察项。

如何将来自多个资源的响应转换为客户的单个一致响应？

Answer 1

平面图运算符是您正在寻找的东西。您可以发出流中的href链接，以便在平面图运算符中将每个链接转换为一个新的可观察对象，该可观察对象将其结果传播到原始流中。我认为这正是您描述的行为。

编辑：改装库提供了很好的界面，可以从链接创建可观察的对象。要详细说明您的示例，首先需要使用map操作符将集合对象转换为某种类型的Iterable。一旦你有了一个可变量，使用flatMap创建一个可观测的项目，这些项目属于可观测的，使用可观测的。from（）。这将以单独排放的形式排放链接。然后再次使用flatMap将每个链接转换为可观察的网络请求，该网络请求将发射转发回原始流。

getCollectionObjectObservable()
  .map(result -> iterable) // transform the object into Iterable( ie. List ) 
  .flatMap(iterable -> Observable.from(iterable))
  .flatMap(link -> createRequestObservable(link))
  .subscribe(result -> /* process the result of each item here */ )