从 Observable 读取对象值

Question

有没有办法可以在下面的代码中从 userObservable 中 return 用户列表。基本上如何读取 Observable 的对象值。

public List<User> getUserList(){
    Observable<Map<String, Object>> userDetailsObservable = getUserDetails(...);
    Observable<Map<String, Object>> userLikesObservable = getUserLikes(...);
    Observable<List<User>> userObservable = Observable.zip(userDetailsObservable,
            userLikesObservable, new Func2<Map<String, Object>, Map<String, Object>, List<User>>() {
                public List<User> call(Map<String, Object> value1, Map<String, Object> value2) {
                    List<User> userList = new ArrayList<User>();
                    //Iterating both maps and composing user list here.
                    return userList;
                }
            });
    userObservable.subscribe(new Subscriber<List<User>>() {
        @Override
        public void onNext(List<User> userList) {
            System.out.println("Merged values " + userList);
        }

        @Override
        public void onError(Throwable error) {
            System.err.println("Error: " + error.getMessage());
        }

        @Override
        public void onCompleted() {
            System.out.println("Sequence complete.");
        }
    });
    // Throws ClassCastException which is expected... How do I get the user list from userObservable
    List<User> userList = List<User> userObservable;

    return userList; //Fetch the user list from userObservable and return
}

Answer 1

您需要订阅userObservable。然后，当数据可用时，您将获得发出的用户列表。

userObservable
    .subscribe(users -> {
        for (User user : users) {
            // Do what you want with user.
        }
    });

编辑：对于 return 列表，您需要使用 toBlocking() call. Then you can use one of the Blocking Observable Operators 以获得所需的效果。 first() 或 single() 很可能适合您。

return userObservable
    .toBlocking()
    .first();

从 Observable 读取对象值

Read object values from Observable

rx-java