我正在尝试将 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 中更新过文档)。但它不会抛出任何错误,任务完成但从未成功。
我不理解这种行为。有什么建议么?我在这里做错了什么?
最佳答案
您不必为任务使用回调 - 我认为 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);
});
}
关于android - 将 Firebase 任务<Void> 包装到 RxJava CompletableEmitter 中?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/56248038/