mirror of
https://github.com/Novaloop-AG/element-x-android.git
synced 2026-11-03 16:10:00 +00:00
Merge pull request #4069 from element-hq/feature/bma/startSync
Always attempt to start the sync when starting the application.
This commit is contained in:
@@ -88,6 +88,7 @@ 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
|
||||||
import kotlinx.coroutines.flow.onEach
|
import kotlinx.coroutines.flow.onEach
|
||||||
|
import kotlinx.coroutines.flow.onStart
|
||||||
import kotlinx.coroutines.launch
|
import kotlinx.coroutines.launch
|
||||||
import kotlinx.parcelize.Parcelize
|
import kotlinx.parcelize.Parcelize
|
||||||
import timber.log.Timber
|
import timber.log.Timber
|
||||||
@@ -196,6 +197,10 @@ class LoggedInFlowNode @AssistedInject constructor(
|
|||||||
) { syncState, networkStatus ->
|
) { syncState, networkStatus ->
|
||||||
Pair(syncState, networkStatus)
|
Pair(syncState, networkStatus)
|
||||||
}
|
}
|
||||||
|
.onStart {
|
||||||
|
// Temporary fix to ensure that the sync is started even if the networkStatus is offline.
|
||||||
|
syncService.startSync()
|
||||||
|
}
|
||||||
.collect { (syncState, networkStatus) ->
|
.collect { (syncState, networkStatus) ->
|
||||||
Timber.d("Sync state: $syncState, network status: $networkStatus")
|
Timber.d("Sync state: $syncState, network status: $networkStatus")
|
||||||
if (syncState != SyncState.Running && networkStatus == NetworkStatus.Online) {
|
if (syncState != SyncState.Running && networkStatus == NetworkStatus.Online) {
|
||||||
|
|||||||
Reference in New Issue
Block a user