Message queuing : branches the enable sending queue mechanism.

This commit is contained in:
ganfra 2024-06-06 17:09:52 +02:00
parent 7100a9d619
commit 026a2cd33a
5 changed files with 74 additions and 4 deletions

View file

@ -114,7 +114,7 @@ interface MatrixClient : Closeable {
* so it's required to manually re-enable it as soon as
* connectivity is back on the device.
*/
suspend fun enableSendingQueue(enable: Boolean)
suspend fun setSendingQueueEnabled(enabled: Boolean)
/**
* Returns the current status of the sending queue as a [StateFlow].

View file

@ -552,8 +552,9 @@ class RustMatrixClient(
}.distinctUntilChanged()
}
override suspend fun enableSendingQueue(enable: Boolean) = withContext(sessionDispatcher) {
client.enableSendingQueue(enable)
override suspend fun setSendingQueueEnabled(enabled: Boolean) = withContext(sessionDispatcher) {
Timber.i("setSendingQueueEnabled($enabled)")
client.enableSendingQueue(enabled)
}
override fun sendingQueueStatus(): StateFlow<Boolean> = mxCallbackFlow {

View file

@ -304,7 +304,7 @@ class FakeMatrixClient(
// no-op
}
override suspend fun enableSendingQueue(enable: Boolean) = enableSendingQueueLambda(enable)
override suspend fun setSendingQueueEnabled(enable: Boolean) = enableSendingQueueLambda(enable)
var sendingQueueStatusFlow = MutableStateFlow(true)
override fun sendingQueueStatus(): StateFlow<Boolean> = sendingQueueStatusFlow