From 89b508c0cfe588ee9cae9acb2bb053886eaf67d0 Mon Sep 17 00:00:00 2001 From: andrekir Date: Sun, 21 Jan 2024 06:36:44 -0300 Subject: [PATCH] refactor: replace `MutableStateFlow` direct assignment with `update` --- .../mesh/repository/network/NetworkRepository.kt | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/app/src/main/java/com/geeksville/mesh/repository/network/NetworkRepository.kt b/app/src/main/java/com/geeksville/mesh/repository/network/NetworkRepository.kt index 2649c98fa..e495e6e81 100644 --- a/app/src/main/java/com/geeksville/mesh/repository/network/NetworkRepository.kt +++ b/app/src/main/java/com/geeksville/mesh/repository/network/NetworkRepository.kt @@ -10,6 +10,7 @@ import com.geeksville.mesh.CoroutineDispatchers import kotlinx.coroutines.flow.MutableStateFlow import kotlinx.coroutines.flow.StateFlow import kotlinx.coroutines.flow.collectLatest +import kotlinx.coroutines.flow.update import kotlinx.coroutines.launch import javax.inject.Inject import javax.inject.Singleton @@ -29,9 +30,10 @@ class NetworkRepository @Inject constructor( init { processLifecycle.coroutineScope.launch(dispatchers.default) { - nsdManagerLazy.get()?.let { manager -> - manager.discoverServices(SERVICE_TYPE).collectLatest { serviceList -> - _resolvedList.value = serviceList + val manager = nsdManagerLazy.get() ?: return@launch + manager.discoverServices(SERVICE_TYPE).collectLatest { serviceList -> + _resolvedList.update { + serviceList .filter { it.serviceName.contains(SERVICE_NAME) } .mapNotNull { manager.resolveService(it) } }