Sulkta-OSS/element-x-ada
3
0
Fork 0
Code Issues 1 Pull requests 10 Projects Releases Packages Wiki Activity Actions

SlidingSyncObserverProxy : avoid fooding flow

Browse source
This commit is contained in:
ganfra 2022-11-04 18:48:47 +01:00
parent a697b8a38f
commit 1095aa13e7
1 changed files with 3 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

3
libraries/matrix/src/main/java/io/element/android/x/matrix/sync/SlidingSyncObserverProxy.kt
View file

@ -6,6 +6,7 @@ import kotlinx.coroutines.flow.MutableSharedFlow
import kotlinx.coroutines.launch import kotlinx.coroutines.launch
import org.matrix.rustcomponents.sdk.SlidingSyncObserver import org.matrix.rustcomponents.sdk.SlidingSyncObserver
import org.matrix.rustcomponents.sdk.UpdateSummary import org.matrix.rustcomponents.sdk.UpdateSummary
import org.matrix.rustcomponents.sdk.setupTracing
class SlidingSyncObserverProxy(private val coroutineScope: CoroutineScope) : SlidingSyncObserver { class SlidingSyncObserverProxy(private val coroutineScope: CoroutineScope) : SlidingSyncObserver {
@ -13,8 +14,10 @@ class SlidingSyncObserverProxy(private val coroutineScope: CoroutineScope) : Sli
val updateSummaryFlow: Flow<UpdateSummary> = updateSummaryMutableFlow val updateSummaryFlow: Flow<UpdateSummary> = updateSummaryMutableFlow
override fun didReceiveSyncUpdate(summary: UpdateSummary) { override fun didReceiveSyncUpdate(summary: UpdateSummary) {
if (summary.rooms.isEmpty()) return
coroutineScope.launch { coroutineScope.launch {
updateSummaryMutableFlow.emit(summary) updateSummaryMutableFlow.emit(summary)
} }
} }
} }