Network Listener Flow

NetworkFlow.kt

@ExperimentalCoroutinesApi
fun notifyNetwork() = channelFlow<Boolean> {
  val networkRequest = NetworkRequest.Builder()
                .addTransportType(NetworkCapabilities.TRANSPORT_WIFI)
                .addTransportType(NetworkCapabilities.TRANSPORT_CELLULAR)
                .build()

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

  connectivityManager.registerNetworkCallback(networkRequest, object : ConnectivityManager.NetworkCallback() {
    override fun onLost(network: Network) {
      super.onLost(network)
        launch {
          channel.offer(false)
        }
     }

    override fun onAvailable(network: Network) {
      super.onAvailable(network)
        launch {
          channel.offer(true)
        }
     }
  })

  awaitClose {
    println("Network closed")
  }
}

NetworkFlowCollector.kt

fun main() {
  CoroutineScope(Dispatchers.Main).launch {
      notifyNetwork().collect {
        println(if (it) "Network connected" else "No Internet")
      }
   }
}