如何等到firebase保存所有数据？

debugcn 发表于 Dev

谢尔马诺

我需要一些有关异步任务和 Firebase 的帮助。我需要在 Firebase 实时数据库上保存n 个itens，但我不知道如何处理回调。

这是我的代码：

 TagRepository tagRepository = new TagRepository();
    for (Tag tag : databaseTags){
        if (user.getTags().containsKey(tag.getId())){
            Completable completable = tagRepository.saveUserOnTag(String.valueOf(tag.getId()), user.getUid());
        }else{
            tagRepository.removeUserOnTag(String.valueOf(tag.getId()), user.getUid());
        }
    }

  public Completable saveUserOnTag(String idTag, String userUid) {
    return io.reactivex.Completable.create(emitter->{
        reference.child(idTag).child("users/").child(userUid).setValue(true).addOnCompleteListener(task -> emitter.onComplete());
    });
}

如果我在此方法上使用回调，则回调将被调用n次，因此我不知道如何知道何时所有这些都已保存，以便我可以继续。

正如您在方法中看到的那样，我正在尝试使用 Completable 进行一些操作，但我真的不知道如何处理它。有什么简单的方法可以同时保存所有数据或控制正在保存的所有数据？？

威利克

抱歉，我不知道 Rx，但这里有一种方法可以在一个 API 调用中插入所有数据。该onComplete()方法是更新完成回调。

Map<String, Object> values = new HashMap<>();
for (Tag tag : databaseTags){
    if (user.getTags().containsKey(tag.getId())){
        values.put(idTag + "/users/" + userUid, true);
    }else{
        tagRepository.removeUserOnTag(String.valueOf(tag.getId()), user.getUid());
    }
}

reference.updateChildren(values, new DatabaseReference.CompletionListener() {
    @Override
    public void onComplete(DatabaseError databaseError, DatabaseReference databaseReference) {
        // all data saved, do next action
    }
});

希望这可以帮助：）

本文收集自互联网，转载请注明来源。

如有侵权，请联系[email protected] 删除。