GiftedHacker/tangem-app-android-audited
1
0
Fork 0
Code Issues Pull requests Projects Releases 1 Packages Wiki Activity Actions

Updated on 2026-08-14

Browse source
This commit is contained in:
Tangem 2023-05-31 19:36:27 +05:00
parent 7a177e3467
commit b406e675f9
1 changed files with 9 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

11
core/datasource/src/main/java/com/tangem/datasource/connection/RealInternetConnectionManager.kt
View file

@ -1,6 +1,7 @@
package com.tangem.datasource.connection
import com.github.pwittchen.reactivenetwork.library.rx2.ReactiveNetwork
import com.github.pwittchen.reactivenetwork.library.rx2.internet.observing.InternetObservingSettings
import com.tangem.utils.coroutines.FeatureCoroutineExceptionHandler
import io.reactivex.BackpressureStrategy
import kotlinx.coroutines.CoroutineScope
@ -11,6 +12,8 @@ import kotlinx.coroutines.flow.StateFlow
import kotlinx.coroutines.flow.stateIn
import kotlinx.coroutines.reactive.asFlow
private const val PING_INTERVAL = 5_000
internal class RealInternetConnectionManager : NetworkConnectionManager {
private val scope =
@ -19,10 +22,14 @@ internal class RealInternetConnectionManager : NetworkConnectionManager {
)
override val isOnlineFlow: StateFlow<Boolean> = ReactiveNetwork
.observeInternetConnectivity()
.observeInternetConnectivity(
InternetObservingSettings.builder()
.interval(PING_INTERVAL)
.build()
)
.toFlowable(BackpressureStrategy.LATEST)
.asFlow()
.stateIn(scope, SharingStarted.Eagerly, initialValue = false)
.stateIn(scope, SharingStarted.Lazily, initialValue = false)
override val isOnline: Boolean
get() = isOnlineFlow.value