Always attempt to start the sync when starting the application.
This commit is contained in:
parent
c316cdb09e
commit
acf7e4655b
1 changed files with 4 additions and 3 deletions
|
|
@ -84,6 +84,7 @@ import io.element.android.libraries.preferences.api.store.EnableNativeSlidingSyn
|
||||||
import io.element.android.services.appnavstate.api.AppNavigationStateService
|
import io.element.android.services.appnavstate.api.AppNavigationStateService
|
||||||
import kotlinx.coroutines.CoroutineScope
|
import kotlinx.coroutines.CoroutineScope
|
||||||
import kotlinx.coroutines.FlowPreview
|
import kotlinx.coroutines.FlowPreview
|
||||||
|
import kotlinx.coroutines.flow.collectIndexed
|
||||||
import kotlinx.coroutines.flow.combine
|
import kotlinx.coroutines.flow.combine
|
||||||
import kotlinx.coroutines.flow.debounce
|
import kotlinx.coroutines.flow.debounce
|
||||||
import kotlinx.coroutines.flow.launchIn
|
import kotlinx.coroutines.flow.launchIn
|
||||||
|
|
@ -196,9 +197,9 @@ class LoggedInFlowNode @AssistedInject constructor(
|
||||||
) { syncState, networkStatus ->
|
) { syncState, networkStatus ->
|
||||||
Pair(syncState, networkStatus)
|
Pair(syncState, networkStatus)
|
||||||
}
|
}
|
||||||
.collect { (syncState, networkStatus) ->
|
.collectIndexed { index, (syncState, networkStatus) ->
|
||||||
Timber.d("Sync state: $syncState, network status: $networkStatus")
|
Timber.d("Sync state: $syncState, network status: $networkStatus, index: $index")
|
||||||
if (syncState != SyncState.Running && networkStatus == NetworkStatus.Online) {
|
if (syncState != SyncState.Running && (index == 0 || networkStatus == NetworkStatus.Online)) {
|
||||||
syncService.startSync()
|
syncService.startSync()
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue