android - 将 Firebase 任务 包装到 RxJava CompletableEmitter 中？

Question

我正在尝试将 Firestore 方法 包装到 CompletableEmitter 中，以便能够在成功/完成时返回 Completable.complete()，在失败时返回 Completable.error()。(该任务是一个 Firestore 操作，用于更新集合中的文档(该文档中的 1 个字段))

This是 firestore method我正在尝试包装成 Completable返回 Task<Void> .这是没有将其包装在 Completable 中的代码:

public static Completable updateDocument(DocumentReference ref, Map<String,Object> fieldsAndValues){
    ref.update(fieldsAndValues)
                .addOnSuccessListener(aVoid -> {
                    Timber.d("SUCCESS");
                }).addOnCompleteListener(task -> {
                    Timber.d("COMPLETE");
                }).addOnFailureListener(e -> {
                    Timber.d("ERROR");
                });
        return Completable.complete();    //just for the sake of returning complete to finish the method...
}

上面的代码按原样执行。

这是我尝试包装该代码的尝试:

public static Completable updateDocument(DocumentReference ref, Map<String,Object> fieldsAndValues){
    return Completable.create(emitter -> ref.update(fieldsAndValues)
       .addOnSuccessListener(aVoid -> emitter.onComplete())
       .addOnCompleteListener(task -> emitter.onComplete())
       .addOnFailureListener(emitter::onError));
}

虽然第一个成功执行(调用了 onSuccess，更新了 Firestore 中的文档)，但包装代码从未从任务到达 onSuccess(从未达到过 onSuccess，从未在 Firestore 中更新过文档)。但它不会抛出任何错误，任务完成但从未成功。

我不理解这种行为。有什么建议么？我在这里做错了什么？

Answer 1

您不必为任务使用回调 - 我认为 api 在这个意义上是有限制的。

您可以使任务阻塞并在执行后对其进行评估，即

public static Completable updateDocument(DocumentReference ref, Map<String,Object> fieldsAndValues){
        return Completable.fromCallable(() -> {
            final Task<Void> task = ref.update(fieldsAndValues);
            Tasks.await(task);
            if(task.isSuccessful()) {
                return Completable.complete();
            } else {
                return Completable.error(new IllegalStateException("Task not successful", task.getException()));
            }
        });
    }

作为您最初的问题，请尝试在闭包中保留对任务的引用，即

public static Completable updateDocument(DocumentReference ref, Map<String, Object> fieldsAndValues) {
        return Completable.create(emitter -> {
            final Task<Void> task = ref.update(fieldsAndValues)
            task.addOnSuccessListener(aVoid -> emitter.onComplete())
                    .addOnCompleteListener(task -> emitter.onComplete())
                    .addOnFailureListener(emitter::onError);
        });
    }