Estoy desconcertado en cuanto a cuál es la mejor manera de lograr esto. Estoy tratando de mantener un total acumulado de valores dobles que estoy recorriendo y sumando, a través de una llamada de red. Todo lo que he leído dice que use DispatchGroup. Mi finalización llama demasiado pronto o no recibe ninguna llamada y probé todas las configuraciones de .enter, .leave y .wait que se me ocurren.
let group = DispatchGroup() var runningTotal: Double = 0.00 ref.observeSingleEvent(of: .value) { (snapshot) in guard let bills = snapshot.value as? [String: AnyObject] else { //error return } for billId in bills.keys { group.enter() print("Entering") Database.database().reference().child("bills").child(billId).observeSingleEvent(of: .value, with: { (snapshot) in guard let bill = snapshot.value as? [String: AnyObject] else { return } if let amount = bill["amount"] as? Double { runningTotal += amount } group.leave() print("Leaving") }) } completion(runningTotal) } group.wait() }Un par de pensamientos:
Evite llamar a wait desde el hilo principal. Los casos de uso para eso son bastante limitados. La notify es una forma mucho más segura de lograr lo mismo.
Asegúrate de llamar a leave desde cada ruta dentro de tu bucle. Esto se puede lograr muy bien con el bloqueo defer .
Asi que:
func foo(completion: @escaping (Double?) -> Void) { ref.observeSingleEvent(of: .value) { snapshot in guard let bills = snapshot.value as? [String: AnyObject] else { //error completion(nil) return } let group = DispatchGroup() var runningTotal = 0.0 for billId in bills.keys { group.enter() print("Entering") Database.database().reference().child("bills").child(billId).observeSingleEvent(of: .value) { snapshot in defer { group.leave() } guard let bill = snapshot.value as? [String: AnyObject] else { return } if let amount = bill["amount"] as? Double { runningTotal += amount } print("Leaving") } } group.notify(queue: .main) { completion(runningTotal) } } }Debe esperar hasta que se completen todas las tareas del grupo y luego llamar al bloque de finalización.
Como abajo.
var runningTotal: Double = 0.00 ref.observeSingleEvent(of: .value) { (snapshot) in guard let bills = snapshot.value as? [String: AnyObject] else { //error return } let group = DispatchGroup() for billId in bills.keys { group.enter() print("Entering") Database.database().reference().child("bills").child(billId).observeSingleEvent(of: .value, with: { (snapshot) in guard let bill = snapshot.value as? [String: AnyObject] else { group.leave() return } if let amount = bill["amount"] as? Double { runningTotal += amount } group.leave() print("Leaving") }) } group.wait() completion(runningTotal) }