SwiftIU/Firebase: как обновлять списки пользователей из Firebase в режиме реального времени и отображать это в пользовательском интерфейсе?

https://www.loom.com/share/de410c2626644dd796ad407fcee7e5c7

^^^ Я прикрепил видео о ткацком станке, демонстрирующее ошибку, с которой я столкнулся, а также код, который у меня есть в настоящее время.

Проблема в том, что пользовательский интерфейс не обновляется сразу и может запутать пользователей. Весь код с точки зрения правильного обновления бэкэнд-функции (это обновление пользовательского интерфейса, который не работает должным образом), я почти уверен, что это связано с тем, как я вызываю функции или саму функцию.

Любая помощь будет принята с благодарностью!

@Published var userRequestInboxUsers = [User]()
@Published var emergencyContactUsers = [User]()

// function to fetch the user requests
func fetchTheUsersRequests() {

  guard let uid = user.id else { return }
  let query = COLLECTION_FOLLOWERS.document(uid).collection("inbox").whereField(
    "currentStatus", isEqualTo: "isPending")

  query.addSnapshotListener(includeMetadataChanges: true) { snapshot, error in
    if let error = error {
      print("There was an error querying the inbox requests: \(error.localizedDescription)")
    } else {

      for request in snapshot!.documents {

        COLLECTION_USERS.document(request.documentID).getDocument { snapshot, error in
          if let error = error {
            print("There was an error fetching the user data: \(error)")
          } else {
            DispatchQueue.main.async {
              guard let userRequestInInbox = try? snapshot?.data(as: User.self) else { return }
              self.userRequestInboxUsers.append(userRequestInInbox)
            }
          }
        }
      }
    }
  }
}

//function that fetches the users contacts (request that have been approved)
func fetchTheUsersContacts() {
  guard let uid = user.id else { return }

  let query = COLLECTION_FOLLOWERS.document(uid).collection("inbox").whereField(
    "currentStatus", isEqualTo: "emergencyContact")

  query.addSnapshotListener(includeMetadataChanges: true) { snapshot, error in
    if let error = error {
      print("There was an error querying the emergency contacts: \(error.localizedDescription)")
    } else {
      for userContact in snapshot!.documents {
        COLLECTION_USERS.document(userContact.documentID).getDocument { snapshot, error in
          if let error = error {
            print("There was an error fetching the user data: \(error)")
          } else {
            DispatchQueue.main.async {
              guard let userEmergencyContactsInInbox = try? snapshot?.data(as: User.self) else {
                return
              }
              self.emergencyContactUsers.append(userEmergencyContactsInInbox)
            }
          }
        }
      }
    }
  }
}

Я пытался вызывать функцию каждый раз, когда появляется представление, но это приводит к дублированию результатов.

В настоящее время я использую прослушиватели снимков для получения доступа в реальном времени, но даже тогда это не работает.

Я структурировал свой бэкэнд, чтобы иметь подколлекцию контактов и подколлекцию запросов, но я получаю ту же проблему с гораздо большим количеством строк кода...

Я думал о переключении на async/await, но я бы предпочел, чтобы мое приложение было совместимо с ios 14+, а не только с 15 и выше.

Я мог бы попробовать использовать строго Combine, а не обратные вызовы, но я не думаю, что это было бы эффективно для решения проблемы в лоб.