6 }
7 }
9+ // Android reports a lifted network block only through this callback.
10+ override fun onBlockedStatusChanged(network: android.net.Network, blocked: Boolean) {
11+ asyncEmitNetworkState(DELAY_MS)
12+ }
13+
14 override fun onCapabilitiesChanged(network: android.net.Network, networkCapabilities: NetworkCapabilities) {
15 asyncEmitNetworkState(DELAY_MS)
16 }
22 // since we want to wait for the result to be updated once:
23 let tempMonitor = NWPathMonitor()
24 var tempPath: NWPath?
25+ let pathLock = NSLock()
27 let semaphore = DispatchSemaphore(value: 0)
29 tempMonitor.pathUpdateHandler = { updatedPath in
30+ // Cancellation does not drain queued updates. Publish only the first path
31+ // and synchronize its retain with the caller reading it on another queue.
32+ pathLock.lock()
33+ defer { pathLock.unlock() }
34+ guard tempPath == nil else {
35+ return
36+ }
37 tempPath = updatedPath
38 semaphore.signal() // Notify that we got the path
39 }
41 return nil
42 }
44+ pathLock.lock()
45+ defer { pathLock.unlock() }
46 return tempPath
47 }