rx-java2 - 如何按字段发出的事件分组？

Question

我有一个班级用户：

class User {
  String companyId;
}

和一类公司：

class Company {
    String id;
    List<User> users;
}

我需要将 a 公司发出的用户“分组”Observable<User>并返回 a Observable<Company>。我有这个：

public Observable<Company> getCompanies(Observable<User> users) {
    return users.distinct(new Func1<User, String>(){
        @Override
        public String call(User user) {
            return user.companyId;
        }
    }).map(new Func1<User, Company>(){
         @Override
         public Company call(User user) {
             return new Company(user.companyId);
         }
    });
}

它有效，但它只是通过 companyId 获得不同的用户。我需要设置List<User>每个公司的。我可以使用任何操作员来解决这个问题吗？

Answer 1

解决了！有groupBy接线员-.-”

public Observable<Company> getCompanies(Observable<User> users) {
    return users.groupBy(new Func1<User, String>(){
        @Override
        public String call(User user) {
            return user.companyId;
        }
    }).flatMap(new Func1<GroupedObservable<String, User>, Observable<List<User>>>() {
                @Override
                public Observable<List<User>> call(GroupedObservable<String, User> grouped) {
                    return grouped.toList();
                }
            }, new Func2<GroupedObservable<String, User>, List<User>, Company>() {
                @Override
                public Company call(GroupedObservable<String, User> grouped, List<User> users) {
                    return new Company(grouped.getKey(), users);
                }
            });