runOnUiThread() replaced by Coroutines

Author: UmerCodez

app/src/main/java/github/umer0586/sensorserver/activities/MainActivity.kt

@@ -11,6 +11,7 @@ import androidx.appcompat.app.ActionBarDrawerToggle
 import androidx.appcompat.app.AppCompatActivity
 import androidx.fragment.app.Fragment
 import androidx.fragment.app.FragmentActivity
+import androidx.lifecycle.lifecycleScope
 import androidx.viewpager2.adapter.FragmentStateAdapter
 import com.google.android.material.navigation.NavigationBarView
 import github.umer0586.sensorserver.R
@@ -21,6 +22,8 @@ import github.umer0586.sensorserver.fragments.ServerFragment
 import github.umer0586.sensorserver.service.SensorService
 import github.umer0586.sensorserver.service.SensorService.LocalBinder
 import github.umer0586.sensorserver.service.ServiceBindHelper
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.launch
 
 class MainActivity : AppCompatActivity(), NavigationBarView.OnItemSelectedListener
 {
@@ -120,7 +123,9 @@ class MainActivity : AppCompatActivity(), NavigationBarView.OnItemSelectedListen
 
  sensorService?.onConnectionsCountChange { count ->
 
- runOnUiThread { setConnectionCountBadge(count) }
+ lifecycleScope.launch(Dispatchers.Main) {
+ setConnectionCountBadge(count)
+ }
  }
 
  }

app/src/main/java/github/umer0586/sensorserver/fragments/ConnectionsFragment.kt

@@ -1,21 +1,21 @@
 package github.umer0586.sensorserver.fragments
 
-import android.content.ComponentName
-import android.content.ServiceConnection
 import android.os.Bundle
 import android.os.IBinder
 import android.util.Log
 import android.view.LayoutInflater
 import android.view.View
 import android.view.ViewGroup
 import androidx.fragment.app.Fragment
+import androidx.lifecycle.lifecycleScope
 import androidx.recyclerview.widget.LinearLayoutManager
 import github.umer0586.sensorserver.databinding.FragmentConnectionsBinding
 import github.umer0586.sensorserver.fragments.customadapters.ConnectionsRecyclerViewAdapter
 import github.umer0586.sensorserver.service.SensorService
 import github.umer0586.sensorserver.service.SensorService.LocalBinder
 import github.umer0586.sensorserver.service.ServiceBindHelper
-import github.umer0586.sensorserver.util.UIUtil
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.launch
 import org.java_websocket.WebSocket
 
 /**
@@ -86,7 +86,9 @@ class ConnectionsFragment : Fragment()
  this.webSockets.addAll(webSockets)
 
  handleNoConnectionsText()
- UIUtil.runOnUiThread { connectionsRecyclerViewAdapter.notifyDataSetChanged() }
+ lifecycleScope.launch(Dispatchers.Main) {
+ connectionsRecyclerViewAdapter.notifyDataSetChanged()
+ }
  }
 
 
@@ -114,12 +116,15 @@ class ConnectionsFragment : Fragment()
 
  private fun handleNoConnectionsText()
  {
- if (webSockets.size > 0) UIUtil.runOnUiThread {
- binding.noConnectionsText.visibility = View.INVISIBLE
+ lifecycleScope.launch(Dispatchers.Main) {
+ if (webSockets.size > 0)
+ binding.noConnectionsText.visibility = View.INVISIBLE
+ else
+ binding.noConnectionsText.visibility = View.VISIBLE
  }
- else UIUtil.runOnUiThread { binding.noConnectionsText.visibility = View.VISIBLE }
  }
 
+
  companion object
  {
  private val TAG: String = ConnectionsFragment::class.java.getSimpleName()

app/src/main/java/github/umer0586/sensorserver/fragments/ServerFragment.kt

@@ -11,6 +11,7 @@ import android.view.ViewGroup
 import android.widget.Toast
 import androidx.core.content.ContextCompat
 import androidx.fragment.app.Fragment
+import androidx.lifecycle.lifecycleScope
 import com.google.android.material.snackbar.Snackbar
 import github.umer0586.sensorserver.R
 import github.umer0586.sensorserver.customextensions.isHotSpotEnabled
@@ -20,8 +21,9 @@ import github.umer0586.sensorserver.service.SensorService.LocalBinder
 import github.umer0586.sensorserver.service.ServerStateListener
 import github.umer0586.sensorserver.service.ServiceBindHelper
 import github.umer0586.sensorserver.setting.AppSettings
-import github.umer0586.sensorserver.util.UIUtil
 import github.umer0586.sensorserver.websocketserver.ServerInfo
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.launch
 import java.net.BindException
 import java.net.UnknownHostException
 
@@ -154,36 +156,38 @@ class ServerFragment : Fragment(), ServerStateListener
  override fun onServerStarted(serverInfo: ServerInfo)
  {
  Log.d(TAG, "onServerStarted() called")
- UIUtil.runOnUiThread {
+ lifecycleScope.launch(Dispatchers.Main) {
+
  showServerAddress("ws://" + serverInfo.ipAddress + ":" + serverInfo.port)
  showPulseAnimation()
 
  binding.startButton.tag = "started"
  binding.startButton.text = "STOP"
 
  showMessage("Server started")
+
  }
  }
 
  override fun onServerStopped()
  {
  Log.d(TAG, "onServerStopped() called ")
 
-  UIUtil.runOnUiThread {
+ lifecycleScope.launch(Dispatchers.Main) {
 
-  hideServerAddress()
-  hidePulseAnimation()
+ hideServerAddress()
+ hidePulseAnimation()
 
-  binding.startButton.tag = "stopped"
-  binding.startButton.text = "START"
+ binding.startButton.tag = "stopped"
+ binding.startButton.text = "START"
 
-  showMessage("Server Stopped")
-  }
+ showMessage("Server Stopped")
+ }
  }
 
  override fun onServerError(ex: Exception?)
  {
- UIUtil.runOnUiThread {
+ lifecycleScope.launch(Dispatchers.Main) {
  if (ex is BindException)
  showMessage("Port already in use")
  else if (ex is UnknownHostException)
@@ -203,7 +207,7 @@ class ServerFragment : Fragment(), ServerStateListener
  override fun onServerAlreadyRunning(serverInfo: ServerInfo)
  {
  Log.d(TAG, "onServerAlreadyRunning() called")
- UIUtil.runOnUiThread {
+ lifecycleScope.launch(Dispatchers.Main) {
  showServerAddress("ws://" + serverInfo.ipAddress + ":" + serverInfo.port)
  Toast.makeText(context, "service running", Toast.LENGTH_SHORT).show()
  binding.startButton.tag = "started"