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

Question

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

这是firestore method我试图包装成一个返回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);
        });
    }