From a330283de54de3bf9cae5d90a849dd59f56b359b Mon Sep 17 00:00:00 2001 From: ganfra Date: Fri, 4 Nov 2022 18:48:47 +0100 Subject: [PATCH] SlidingSyncObserverProxy : avoid fooding flow --- .../element/android/x/matrix/sync/SlidingSyncObserverProxy.kt | 3 +++ 1 file changed, 3 insertions(+) diff --git a/libraries/matrix/src/main/java/io/element/android/x/matrix/sync/SlidingSyncObserverProxy.kt b/libraries/matrix/src/main/java/io/element/android/x/matrix/sync/SlidingSyncObserverProxy.kt index bac8e9cf1c..08e8b69dd1 100644 --- a/libraries/matrix/src/main/java/io/element/android/x/matrix/sync/SlidingSyncObserverProxy.kt +++ b/libraries/matrix/src/main/java/io/element/android/x/matrix/sync/SlidingSyncObserverProxy.kt @@ -6,6 +6,7 @@ import kotlinx.coroutines.flow.MutableSharedFlow import kotlinx.coroutines.launch import org.matrix.rustcomponents.sdk.SlidingSyncObserver import org.matrix.rustcomponents.sdk.UpdateSummary +import org.matrix.rustcomponents.sdk.setupTracing class SlidingSyncObserverProxy(private val coroutineScope: CoroutineScope) : SlidingSyncObserver { @@ -13,8 +14,10 @@ class SlidingSyncObserverProxy(private val coroutineScope: CoroutineScope) : Sli val updateSummaryFlow: Flow = updateSummaryMutableFlow override fun didReceiveSyncUpdate(summary: UpdateSummary) { + if (summary.rooms.isEmpty()) return coroutineScope.launch { updateSummaryMutableFlow.emit(summary) } } + } \ No newline at end of file