logic/com.wire.kalium.logic.network/NetworkStateObserverImpl

NetworkStateObserverImpl

internal actual class NetworkStateObserverImpl : NetworkStateObserver

internal expect class NetworkStateObserverImpl : NetworkStateObserver

internal actual class NetworkStateObserverImpl : NetworkStateObserver

Constructors

constructor(connectivityManager: ConnectivityManager, kaliumDispatcher: KaliumDispatcher = KaliumDispatcherImpl)

constructor(appContext: Context, kaliumDispatcher: KaliumDispatcher = KaliumDispatcherImpl)

constructor()

Functions

delayBeforeSyncRetry

internal suspend fun NetworkStateObserver.delayBeforeSyncRetry(retryDelay: Duration, exponentialDurationHelper: ExponentialDurationHelper, logger: KaliumLogger, syncType: SyncType, timeSource: TimeSource = TimeSource.Monotonic, onRetryStateChanged: suspend (SyncRetryStatus) -> Unit = {}, retryController: SyncRetryController = SyncRetryController(), failureGeneration: Long? = null, previousNetworkId: String? = observeCurrentNetwork().value?.id)

Waits for retryDelay before the next sync retry attempt, completing earlier if internet connectivity comes back in the meantime, or if a validated network other than previousNetworkId becomes available.

delayUntilConnectedWithInternetAgain

open suspend fun delayUntilConnectedWithInternetAgain(delay: Duration, previousNetworkId: String?): Boolean

observeCurrentNetwork

actual open override fun observeCurrentNetwork(): StateFlow<CurrentNetwork?>

expect open override fun observeCurrentNetwork(): StateFlow<CurrentNetwork?>

actual open override fun observeCurrentNetwork(): StateFlow<CurrentNetwork?>

observeNetworkState

actual open override fun observeNetworkState(): StateFlow<NetworkState>

expect open override fun observeNetworkState(): StateFlow<NetworkState>

actual open override fun observeNetworkState(): StateFlow<NetworkState>