summaryrefslogtreecommitdiffhomepage
path: root/android/lib/talpid/src/main
diff options
context:
space:
mode:
authorJonatan Rhodin <jonatan.rhodin@mullvad.net>2025-02-26 16:08:20 +0100
committerJonatan Rhodin <jonatan.rhodin@mullvad.net>2025-02-26 16:11:17 +0100
commit7ad3066b9ef0717eb4e36e306fffe4b01f506d14 (patch)
treed04a966373d85bad78f78e81095c65927427950f /android/lib/talpid/src/main
parent5ba686d1ac45509cba636d717bb6729865105cf3 (diff)
downloadmullvadvpn-7ad3066b9ef0717eb4e36e306fffe4b01f506d14.tar.xz
mullvadvpn-7ad3066b9ef0717eb4e36e306fffe4b01f506d14.zip
Fix spamming of connectivity changed events
Diffstat (limited to 'android/lib/talpid/src/main')
-rw-r--r--android/lib/talpid/src/main/kotlin/net/mullvad/talpid/ConnectivityListener.kt2
1 files changed, 2 insertions, 0 deletions
diff --git a/android/lib/talpid/src/main/kotlin/net/mullvad/talpid/ConnectivityListener.kt b/android/lib/talpid/src/main/kotlin/net/mullvad/talpid/ConnectivityListener.kt
index b702a39a6e..6e334a9ead 100644
--- a/android/lib/talpid/src/main/kotlin/net/mullvad/talpid/ConnectivityListener.kt
+++ b/android/lib/talpid/src/main/kotlin/net/mullvad/talpid/ConnectivityListener.kt
@@ -13,6 +13,7 @@ import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.flow.MutableStateFlow
import kotlinx.coroutines.flow.SharingStarted
import kotlinx.coroutines.flow.StateFlow
+import kotlinx.coroutines.flow.distinctUntilChanged
import kotlinx.coroutines.flow.map
import kotlinx.coroutines.flow.merge
import kotlinx.coroutines.flow.onEach
@@ -107,6 +108,7 @@ class ConnectivityListener(private val connectivityManager: ConnectivityManager)
}
}
.map { it.any { it.value.hasInternetCapability() } }
+ .distinctUntilChanged()
}
private fun NetworkCapabilities?.hasInternetCapability(): Boolean =