GlobalPresenter.java 文件源码

private Func1<Chat, Observable<Users>> getUsers() {
    return new Func1<Chat, Observable<Users>>() {
        @Override
        public Observable<Users> call(Chat chat) {
            firstKey = chat.getFirstKey();
            List<Observable<User>> list = new ArrayList<>();
            for (Message m : chat.getMessages())
                list.add(userService.getUser(m.getUid()));

            return Observable.zip(list, new FuncN<Users>() {
                @Override
                public Users call(Object... args) {
                    ArrayList<User> users = new ArrayList<>();
                    for (Object o: args) users.add((User)o);
                    return new Users(users);
                }
            });
        }
    };
}