New Feature

Users can now select and deselect sensors from the list while streaming. This allows the app to send data from different sensors dynamically, without needing to stop and restart the stream."

Author: UmerCodez

app/src/main/java/com/github/umer0586/sensagram/model/service/SensorStreamingService.kt

@@ -118,6 +118,13 @@ class SensorStreamingService : Service() {
             sensors = settingsRepository.selectedSensors.first().toSensors(applicationContext)
         )
 
+        scope.launch {
+
+            settingsRepository.selectedSensors.collect{
+                sensorStreamer?.changeSensors(it.toSensors(applicationContext))
+            }
+        }
+
         sensorStreamer?.onStreamingStarted { info ->
             streamingStartedCallBack?.invoke(info)
             val notificationIntent = Intent(applicationContext, MainActivity::class.java)

app/src/main/java/com/github/umer0586/sensagram/model/streamer/SensorStreamer.kt

@@ -45,7 +45,7 @@ class SensorStreamer(
     val address: String,
     val portNo: Int,
     val samplingRate : Int,
-    val sensors: List<Sensor>
+    private var sensors: List<Sensor>
 ) : SensorEventListener {
 
 
@@ -122,6 +122,31 @@ class SensorStreamer(
         onError = callBack
     }
 
+    fun changeSensors(newSensors : List<Sensor>){
+
+        if(!isStreaming)
+            return
+
+        sensors.forEach {
+            sensorManager.unregisterListener(this, it)
+        }
+
+        newSensors.forEach{
+            sensorManager.registerListener(this, it, samplingRate, handler)
+        }
+
+        // Avoid declaring 'sensors' property as a mutable list and then doing 'sensors.clear()' followed by 'sensors.addAll(newSensors)'.
+        // This can throw a ConcurrentModificationException, leading to app crashes.
+        // The crash occurs because the list is being modified while it's being iterated over,
+        // which happens when the user frequently selects and deselects sensors from the list during streaming.
+        //
+        // One solution is to use an iterator, as explained here: https://stackoverflow.com/questions/50032000/how-to-avoid-concurrentmodificationexception-kotlin
+        // Alternatively, declaring 'sensors' as a 'var' and reassigning it (tested and works without crashes) is a simpler and effective fix.
+
+        sensors = newSensors
+
+    }
+
     override fun onSensorChanged(sensorEvent: SensorEvent) {
 
         val sensorData = mutableMapOf<String,Any>()