如何在 RX Java 中实现方法

我最近刚开始学习 RX Java，我想了解如何在 RX 中重写此方法，是否可能？

@Override
    public void loadExamples(String language) {
        showProgress();
        mDatabase.collection(COLLECTION_PATH)
                .get()
                .addOnCompleteListener(task -> {
                    if (task.isSuccessful()) {
                        List<Example> exampleList = new ArrayList<>();
                        for (QueryDocumentSnapshot document : Objects.requireNonNull(task.getResult())) {
                            Example example = document.toObject(Example.class);
                            if (example.getLanguage().equals(language)) {
                                exampleList.add(example);
                            }
                        }
                        updateUi(exampleList);
                    } else {
                        handleError(task.getException());
                    }
                });
    }