GeoFire observeReady 在 Swift 中过早执行

Question

在以下函数中，我正在执行初始 geofire 搜索查询，并希望处理找到的所有键，将它们附加到数组并将整个数组发回。

问题是 observeReady 代码块执行得太早，因此发送了一个空数组（即使在该范围内找到键，在第一次加载时也没有显示）。

我知道 observeSingleEvent 调用是 asynchronous 并且可能导致此行为，所以我的问题是，我如何管理它并确保在执行 handler 在 observeReady 块内调用？

func fetchInitialNearbyVenues(deviceLocation: CLLocation, radius: Double, handler: @escaping ([Venue]) -> ()) {

        self.venuesArray.removeAll() 
        var savedByUsers = [String : String]() 

        let query = self.GEOFIRE_VENUES_LOC.query(at: deviceLocation, withRadius: radius) 

            query.observe(.keyEntered) { (key: String!, venueLocation: CLLocation!) in 

                self.REF_VENUES.child(key).observeSingleEvent(of: .value, with: { (snapshot) in 

                  //process snapshot create and append Venue object to array
                  //...
                  //...

                  self.venuesArray.append(venue) //append Venue to array

                })//end observeSingleEvent

            }//end geofire query observe

        query.observeReady {
            handler(self.venuesArray) //PROBLEM: This gets executed prematurely thus sending an empty array via handler 
        }

    }//end func

Answer 1

您看到的是预期行为。 observeReady 保证在调用所有相应的 observe(.keyEntered) 之后触发。您可以使用一些简单的日志记录语句来验证这一点：

query.observe(.keyEntered) { (key: String!, venueLocation: CLLocation!) in 
   print(".keyEntered")
}
query.observeReady {
   print(".observeReady")
}

当你运行这将打印：

.keyEntered

.keyEntered

...

.observeReady

这符合 API 的工作原理。但是在 .keyEntered 中，您正在从 Firebase 加载额外的数据，这是异步发生的。在 .observeReady 触发后，这些调用可能确实 完成。

所以您需要自己实现必要的同步。一种检测是否已加载所有附加数据的简单方法是对仍需要加载数据的所有键进行计数。因此，您 +1 每次添加密钥，并且 -1 每次加载场地数据时：

let venuesToLoadCount = 0 query.observe(.keyEntered) { (key: String!, venueLocation: CLLocation!) in venuesToLoadCount = venuesToLoadCount + 1 self.REF_VENUES.child(key).observeSingleEvent(of: .value, with: { (snapshot) in venuesToLoadCount = venuesToLoadCount - 1 if venuesToLoadCount == 0 { print("All done") } } } query.observeReady { if venuesToLoadCount == 0 { print("All done") } }

GeoFire observeReady 在 Swift 中过早执行

GeoFire observeReady gets executed prematurely in Swift

firebase

swift

geofire