Extract common code to update the Flow value

core/data/src/main/java/com/google/samples/apps/nowinandroid/core/data/util/ConnectivityManagerNetworkMonitor.kt

@@ -37,11 +37,18 @@ class ConnectivityManagerNetworkMonitor @Inject constructor(
 ) : NetworkMonitor {
     override val isOnline: Flow<Boolean> = callbackFlow {
         val connectivityManager = context.getSystemService<ConnectivityManager>()
-            ?: run {
+        if (connectivityManager == null) {
-                channel.trySend(false)
+            channel.trySend(false)
-                channel.close()
+            channel.close()
-                return@callbackFlow
+            return@callbackFlow
-            }
+        }
+
+        /**
+         * Sends the latest connectivity status to the underlying channel.
+         */
+        fun update() {
+            channel.trySend(connectivityManager.isCurrentlyConnected())
+       }
 
         /**
          * The callback's methods are invoked on changes to *any* network, not just the active
@@ -49,20 +56,14 @@ class ConnectivityManagerNetworkMonitor @Inject constructor(
          * ConnectivityManager.
          */
         val callback = object : NetworkCallback() {
-            override fun onAvailable(network: Network) {
+            override fun onAvailable(network: Network) = update()
-                channel.trySend(connectivityManager.isCurrentlyConnected())
-            }
 
-            override fun onLost(network: Network) {
+            override fun onLost(network: Network) = update()
-                channel.trySend(connectivityManager.isCurrentlyConnected())
-            }
 
             override fun onCapabilitiesChanged(
                 network: Network,
                 networkCapabilities: NetworkCapabilities,
-            ) {
+            ) = update()
-                channel.trySend(connectivityManager.isCurrentlyConnected())
-            }
         }
 
         connectivityManager.registerNetworkCallback(
@@ -72,7 +73,7 @@ class ConnectivityManagerNetworkMonitor @Inject constructor(
             callback,
         )
 
-        channel.trySend(connectivityManager.isCurrentlyConnected())
+        update()
 
         awaitClose {
             connectivityManager.unregisterNetworkCallback(callback)