firestore onSuccess 监听器不起作用

Question

我正在尝试从我的数据库中下载一些测验对象。 下面的函数是从某个activity的onCreate中调用的。

 private void downloadQuizzesFromCloud(){

        String user_id = FirebaseAuth.getInstance().getCurrentUser().getUid();
        final FirebaseFirestore db = FirebaseFirestore.getInstance();
        String user_quizzes_path = "users/".concat(user_id).concat("/quizzes");
        Query userQuizzes = db.collection(user_quizzes_path);

        userQuizzes.get()
                .addOnCompleteListener(new OnCompleteListener<QuerySnapshot>() {
                    @Override
                    public void onComplete(@NonNull Task<QuerySnapshot> task) {
                        if (task.isSuccessful()) {
                            quizzes.clear();
                            for (QueryDocumentSnapshot document : task.getResult()) {

                                Quiz quizDownloaded = getQuizFromCloud(document.getId());
                                quizzes.add(quizDownloaded);
                            }
                            Toast.makeText(QuizzesActivity.this,"downloaded to list ".concat(String.valueOf(quizzes.size()).concat("  quizzes")), Toast.LENGTH_SHORT).show();
                            //TODO put in recycle adapter
                        } else { }
                    }
                });

    }

（user_quizzes_path 包含存储在云上的测验对象集合的正确路径）

我调试了这个函数，发现命令后：

 userQuizzes.get()
            .addOnCompleteListener(new OnCompleteListener<QuerySnapshot>()

函数完成执行，即不检查和执行 onComplete 的情况，只是跳过所有这些代码。

我试图在 firebase 的文档中找到它，但没有找到任何东西。 为什么会发生这种情况，我该如何解决？

在此不胜感激，谢谢！

Answer 1

从 Firestore 服务器完成读取操作后，将调用 onComplete。如果它没有被调用，我可以看到两个可能的原因：

1. 您没有连接到服务器。除非您之前读取过数据（并且它位于 Firestore 客户端维护的本地数据库中），否则这意味着读取永远不会在本地完成。
2. 您没有异步思考。请注意，数据是从服务器异步读取的，在您调用get() 和onComplete 触发之间可能有一段时间。要测试是否是这种情况，请在if (task.isSuccessful()) { 上放置一个断点并在调试器中运行该应用程序。从服务器读取数据时将触发断点。

Answer 2

使用回调接口。就像下面这样。

private void downloadQuizzesFromCloud(Consumer listener) {

    String user_id = FirebaseAuth.getInstance().getCurrentUser().getUid();

    final FirebaseFirestore db = FirebaseFirestore.getInstance();

    String user_quizzes_path = "users/".concat(user_id).concat("/quizzes");

    Query userQuizzes = db.collection(user_quizzes_path);

    userQuizzes.get()
            .addOnCompleteListener(new OnCompleteListener<QuerySnapshot>() {
                @Override
                public void onComplete(@NonNull Task<QuerySnapshot> task) {
                    if (task.isSuccessful()) {
                        List<Quiz> quizzes = new ArrayList<>();
                        for (QueryDocumentSnapshot document : task.getResult()) {
                            Quiz quizDownloaded = getQuizFromCloud(document.getId());
                            quizzes.add(quizDownloaded);
                        }
                        listener.onGet(quizzes);
                        Toast.makeText(QuizzesActivity.this,"downloaded to list ".concat(String.valueOf(quizzes.size()).concat("  quizzes")), Toast.LENGTH_SHORT).show();
                        //TODO put in recycle adapter
                    } else { }
                }
            });

 } 
 interface Consumer {
    void onGet(List<Quiz> quizzes);
 }