使用RxJava创建可观察的

Question

我在创建一个将返回对象列表的可观察对象时遇到了麻烦。我有一个ID列表，想对我的数据库提出一个请求。在这种情况下，我使用的是Firebase。当得到一个结果时，我希望将这些对象中的每一个编译成一个列表，然后返回该列表。我需要在返回之前等待所有的对象都返回。我在我的视图模型反序列化器类中这样做。这是我的代码。

private class Deserializer implements Function<QuerySnapshot, ArrayList<User>>{
    @Override
    public ArrayList<User> apply(QuerySnapshot input) {

        List<DocumentSnapshot> temp = input.getDocuments();
        final ArrayList<User> users = new ArrayList<>();
        List<String> idList = new ArrayList<>();

        for (DocumentSnapshot snapshot: temp){
            String userId= snapshot.get("userId").toString();
            idList.add(userId);
        }

        //Create observable and make request to firebase
        //compile all the returned into a list return that list
    }

}

有几种方法可以从firebase数据库中返回数据，我可以返回Documentsnapshot任务，或者使用回调来返回数据，如下所示

public void getUser(String userId, final Callback callback){

    DocumentReference docRef = db.collection(DATABASE_COLLECTION_USERS).document(userId);
    docRef.get().addOnSuccessListener(new OnSuccessListener<DocumentSnapshot>() {
        @Override
        public void onSuccess(DocumentSnapshot documentSnapshot) {
            callback.result(documentSnapshot.toObject(User.class));
        }
    });
} 

然后在调用此函数时添加回调。比如getUser(id，新回调{}）；

我真正的问题是如何把所有的请求联系在一起。我知道使用RxJava是一个解决方案。但是我对RXJava不了解。这与我之前问过的使用mongodb和nodejs解决promise的问题非常相似。那是在Nodejs。但是我想使用RxJava来完成这个任务

Answer 1

对于任何游荡的人，我通过创建一个云函数解决了这个问题，该函数获取一个ID列表，在数据库中搜索用户并返回用户列表。这使得我的客户不需要做任何工作。我在我的问题中用了同样的想法与链接中的promise。谢谢