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

Protect call to client.enableAllSendQueues

Browse source 
Fixes https://github.com/element-hq/element-x-android-rageshakes/issues/3375 and other rageshakes.
This commit is contained in:
Benoit Marty 2024-11-18 15:15:10 +01:00
parent 3b14e01dec
commit dbcc6e6181
1 changed files with 8 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

11
libraries/matrix/impl/src/main/kotlin/io/element/android/libraries/matrix/impl/RustMatrixClient.kt
View file

@ -12,6 +12,7 @@ import io.element.android.libraries.androidutils.file.safeDelete
import io.element.android.libraries.core.bool.orFalse import io.element.android.libraries.core.bool.orFalse
import io.element.android.libraries.core.coroutine.CoroutineDispatchers import io.element.android.libraries.core.coroutine.CoroutineDispatchers
import io.element.android.libraries.core.coroutine.childScope import io.element.android.libraries.core.coroutine.childScope
import io.element.android.libraries.core.data.tryOrNull
import io.element.android.libraries.featureflag.api.FeatureFlagService import io.element.android.libraries.featureflag.api.FeatureFlagService
import io.element.android.libraries.matrix.api.MatrixClient import io.element.android.libraries.matrix.api.MatrixClient
import io.element.android.libraries.matrix.api.core.DeviceId import io.element.android.libraries.matrix.api.core.DeviceId
@ -616,9 +617,13 @@ class RustMatrixClient(
.distinctUntilChanged() .distinctUntilChanged()
} }
override suspend fun setAllSendQueuesEnabled(enabled: Boolean) = withContext(sessionDispatcher) { override suspend fun setAllSendQueuesEnabled(enabled: Boolean) {
Timber.i("setAllSendQueuesEnabled($enabled)") withContext(sessionDispatcher) {
client.enableAllSendQueues(enabled) Timber.i("setAllSendQueuesEnabled($enabled)")
tryOrNull {
client.enableAllSendQueues(enabled)
}
}
} }
override fun sendQueueDisabledFlow(): Flow<RoomId> = mxCallbackFlow { override fun sendQueueDisabledFlow(): Flow<RoomId> = mxCallbackFlow {