java - RX java 将可观察量与一对多关系相结合

Question

我有一个 Observer 对象，它订阅了一个 Observable。Observable 对数据库执行 SQL 查询，获取多个结果，然后执行

    .forEach(...)

现在我需要添加第二个 SQL 查询来用更多数据填充该对象。这次结果只有一个特定值。我看到有一个 zip 函数，但它根据文档进行一对一配对。我需要构造如下所示的对象:

    MyObject{
        int i;
        List<AnotherObject>;
    }

Answer 1

您可以使用toList()关于Observable第一个查询返回，将其转换为 Single<List> 。然后，您可以使用zipWith将其与第二个查询的结果结合起来，您可以返回 Single ，因为它只发出一项。

query1() // Returns Observable<AnotherObject>
  .toList()  // Gives you Single<List<AnotherObject>>
  .zipWith(query2(), (result1, result2) -> new MyObject(result1, result2)))
  ...