Sync: remove distincUntilChanged which can cause sync to stay blocked (#1044)

Co-authored-by: ganfra <francoisg@element.io>
This commit is contained in:
ganfra
2023-08-09 20:59:04 +02:00
committed by GitHub
parent 226a3dbf28
commit 2a1a6bcdd9

View File

@@ -72,7 +72,6 @@ import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.FlowPreview
import kotlinx.coroutines.flow.combine
import kotlinx.coroutines.flow.debounce
import kotlinx.coroutines.flow.distinctUntilChanged
import kotlinx.coroutines.launch
import kotlinx.parcelize.Parcelize
import timber.log.Timber
@@ -165,7 +164,6 @@ class LoggedInFlowNode @AssistedInject constructor(
) { syncState, networkStatus ->
Pair(syncState, networkStatus)
}
.distinctUntilChanged()
.collect { (syncState, networkStatus) ->
Timber.d("Sync state: $syncState, network status: $networkStatus")
if (syncState != SyncState.Running && networkStatus == NetworkStatus.Online) {