mirror/Meshtastic-Android
1
0
Fork 0
mirror of https://github.com/meshtastic/Meshtastic-Android.git synced 2026-02-05 21:33:01 -05:00
Code Issues Packages Projects Releases Wiki Activity

fix: network discovery list concurrency handling

Browse Source
This commit is contained in:
andrekir
2023-11-28 18:32:09 -03:00
parent 1a24ebc9d5
commit 49e0d32fa4
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
app/src/main/java/com/geeksville/mesh/repository/network/NetworkRepository.kt
View File

@@ -14,6 +14,7 @@ import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.flow.MutableStateFlow
import kotlinx.coroutines.flow.StateFlow
import kotlinx.coroutines.flow.callbackFlow
import kotlinx.coroutines.flow.update
import kotlinx.coroutines.launch
import javax.inject.Inject
import javax.inject.Singleton
@@ -51,9 +52,11 @@ class NetworkRepository @Inject constructor(
processLifecycle.coroutineScope.launch(dispatchers.default) {
nsdManagerLazy.get()?.let { manager ->
manager.discoverServices(SERVICE_TYPE).collect { serviceList ->
_resolvedList.value = serviceList
.filter { it.serviceName == SERVICE_NAME }
.mapNotNull { manager.resolveService(it) }
_resolvedList.update {
serviceList
.filter { it.serviceName == SERVICE_NAME }
.mapNotNull { manager.resolveService(it) }
}
}
}
}