From b80685dcfba4b1dbcedcdcd8a9f504d5b384b88d Mon Sep 17 00:00:00 2001 From: Vitor Pamplona Date: Thu, 28 Aug 2025 14:17:58 -0400 Subject: [PATCH] Protects this flow against lots of similar emissions --- .../amethyst/service/connectivity/ConnectivityManager.kt | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/amethyst/src/main/java/com/vitorpamplona/amethyst/service/connectivity/ConnectivityManager.kt b/amethyst/src/main/java/com/vitorpamplona/amethyst/service/connectivity/ConnectivityManager.kt index e6eb1cc85..c0e39c4c7 100644 --- a/amethyst/src/main/java/com/vitorpamplona/amethyst/service/connectivity/ConnectivityManager.kt +++ b/amethyst/src/main/java/com/vitorpamplona/amethyst/service/connectivity/ConnectivityManager.kt @@ -24,6 +24,7 @@ import android.app.Application import kotlinx.coroutines.CoroutineScope import kotlinx.coroutines.flow.SharingStarted import kotlinx.coroutines.flow.StateFlow +import kotlinx.coroutines.flow.distinctUntilChanged import kotlinx.coroutines.flow.map import kotlinx.coroutines.flow.stateIn @@ -37,7 +38,7 @@ class ConnectivityManager( scope: CoroutineScope, ) { val status: StateFlow = - ConnectivityFlow(app).status.stateIn( + ConnectivityFlow(app).status.distinctUntilChanged().stateIn( scope, SharingStarted.WhileSubscribed(30000), ConnectivityStatus.Off,