将 Firebase Task<Void> 包装到 RxJava CompletableEmitter 中？

Question

我正在尝试将 Firestore 方法 包装到 CompletableEmitter 中，以便能够 return Completable.complete() on success/complete，并且Completable.error() 失败。（该任务是一个 Firestore 操作，用于更新集合中的文档（该文档中的 1 个字段））

This is the firestore method I am trying to wrap into a Completable 其中 return 是 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

你 subscribed 返回完成了吗？ ref.update() 除非您订阅它，否则将永远不会执行

updateDocument(...)
    .subscribe(...) // <- this

注意：你的第一个代码也有问题。 Completables 应该在 subscribed 时执行。但是在您的第一个代码中，它是在您调用 updateDocument() 时执行的。例如，如果您执行 Completable c = updateDocument(...)，它不应该更新文档，因为您还没有 subscribe()，但是您的第一个代码将更新文档。

Answer 2

您不一定非要为任务使用回调 - 我认为 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);
        });
    }

将 Firebase Task<Void> 包装到 RxJava CompletableEmitter 中？

Wrapping a Firebase Task<Void> into RxJava CompletableEmitter?

android

firebase

rx-java

rx-java2

google-cloud-firestore