Monitor network connectivity in Swift using an async stream

NetworkConnectivityAsyncStream.swift

import Foundation
import Network

enum NetworkConnectivity {
    case online
    case offline
    case unknown
}

let networkConnectivity = AsyncStream(NetworkConnectivity.self) { continuation in
    let queue = DispatchQueue(label: "NetworkConnectivityStream")
    let pathMonitor = NWPathMonitor()
    pathMonitor.pathUpdateHandler = { path in
        continuation.yield(path.mapToNetworkConnectivity())
    }
    continuation.onTermination = { reason in
        pathMonitor.cancel()
    }
    continuation.yield(pathMonitor.currentPath.mapToNetworkConnectivity())
    pathMonitor.start(queue: queue)
}

private extension NWPath {
    func mapToNetworkConnectivity() -> NetworkConnectivity {
        switch status {
        case .satisfied:
            .online
        case .unsatisfied:
            .offline
        case .requiresConnection:
            .unknown
        @unknown default:
            .unknown
        }
    }
}

for await status in networkConnectivity {
    print("Status: \(status)")
}