将对象的Single转换为RxJava中同一对象的内部字段的Single

Question

我有一个嵌入了特征模型的用户模型

public class User {
    private List<Caracteristic> cracteristics;
}

使用Flowable和rxJava我想将Single<List<User>>转换为Single<List<Caracteristics>>

@Controller("cars")
 public class CaracteristicController() {

     public Single<List<User> list() {
          return Flowable.fromPublisher(
                   getCollection().find(exists("caracteristics")))
                   .toList();
     }

     private MongoCollection<User> getCollection() {
         return dbClient
            .getDatabase(dbConfiguration.getDatabaseName())
            .getCollection(dbConfiguration.getCollectionName(), User.class);
     }

 }

用户模型是MongoDB数据库中的文档

{
  "name" : "name",
  "caracteristics" : [
    {
    "desc" : "carac 1",
    "ref" : "ROO12"
  },
  {
    "desc" : "carac 2",
    "ref" : "ROO14"
  }]
}

我不知道如何操作Flowable或Single以返回Caracteristic对象的列表，而不是用户。

Answer 1

如果要获取所有用户的所有特征的列表，可以像这样实现：

Single<List<User>> users = ...;
Single<List<Characteristics>> characteristics = users
    .flatMapObservable(Observable::fromIterable)
    .flatMapIterable(user -> user.characteristics)
    .toList();

Answer 2

您可以使用flatMapIterable运算符将所有用户对象的特征列表合并到Single中。

public Single<List<Characteristic>> list() {
  return Flowable.fromPublisher(getCollection().find(exists("caracteristics")))
    .flatMapIterable((user) -> user.characteristics)
    .toList();
}

private MongoCollection<User> getCollection() {
  return MongoClients.create()
    .getDatabase("db")
    .getCollection("collection", User.class);
}