ConnectivityManagerExt.kt

fun ConnectivityManager.observeAdapterConnectivity(): Flow<Boolean> {
    return callbackFlow {
        val callback = object: ConnectivityManager.NetworkCallback() {
            override fun onAvailable(network: Network) {
                trySendBlocking(true)
            }

            override fun onLost(network: Network) {
                trySendBlocking(false)
            }
        }
        registerDefaultNetworkCallback(callback)
        awaitClose {
            unregisterNetworkCallback(callback)
        }
    }
}