NetworkInfo.kt

class NetworkInfo {

    @Suppress("DEPRECATION")
    @ExperimentalCoroutinesApi
    fun checkConnection(context: Context) = callbackFlow{

        val connectivityManager = context.getSystemService(Context.CONNECTIVITY_SERVICE) as ConnectivityManager

        val networkRequest = NetworkRequest.Builder()
            .addTransportType(NetworkCapabilities.TRANSPORT_CELLULAR)
            .addTransportType(NetworkCapabilities.TRANSPORT_WIFI)
            .build()

        val networkCallback = object : ConnectivityManager.NetworkCallback(){
            override fun onAvailable(network: Network) {
                offer(true)
            }
            override fun onUnavailable() {
                offer(false)
            }
            override fun onLost(network: Network) {
                offer(false)
            }
        }

        if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O){
            connectivityManager.requestNetwork(networkRequest, networkCallback, 2000)
        } else{
            connectivityManager.activeNetworkInfo ?: offer(false)
            connectivityManager.registerNetworkCallback(networkRequest, networkCallback)
        }

        awaitClose { connectivityManager.unregisterNetworkCallback(networkCallback) }
    }
}