@@ -84,11 +84,11 @@ import io.element.android.libraries.preferences.api.store.EnableNativeSlidingSyn
8484import io.element.android.services.appnavstate.api.AppNavigationStateService
8585import kotlinx.coroutines.CoroutineScope
8686import kotlinx.coroutines.FlowPreview
87- import kotlinx.coroutines.flow.collectIndexed
8887import kotlinx.coroutines.flow.combine
8988import kotlinx.coroutines.flow.debounce
9089import kotlinx.coroutines.flow.launchIn
9190import kotlinx.coroutines.flow.onEach
91+ import kotlinx.coroutines.flow.onStart
9292import kotlinx.coroutines.launch
9393import kotlinx.parcelize.Parcelize
9494import timber.log.Timber
@@ -197,9 +197,13 @@ class LoggedInFlowNode @AssistedInject constructor(
197197 ) { syncState, networkStatus ->
198198 Pair (syncState, networkStatus)
199199 }
200- .collectIndexed { index, (syncState, networkStatus) ->
201- Timber .d(" Sync state: $syncState , network status: $networkStatus , index: $index " )
202- if (syncState != SyncState .Running && (index == 0 || networkStatus == NetworkStatus .Online )) {
200+ .onStart {
201+ // Temporary fix to ensure that the sync is started even if the networkStatus is offline.
202+ syncService.startSync()
203+ }
204+ .collect { (syncState, networkStatus) ->
205+ Timber .d(" Sync state: $syncState , network status: $networkStatus " )
206+ if (syncState != SyncState .Running && networkStatus == NetworkStatus .Online ) {
203207 syncService.startSync()
204208 }
205209 }
0 commit comments