ehealthsolutions/element-x-android
3
0
Fork 0
mirror of https://github.com/Novaloop-AG/element-x-android.git synced 2026-11-03 16:10:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

Makes sendMessage suspend

Browse Source
This commit is contained in:
ganfra
2022-11-09 17:24:56 +01:00
parent 0573ea547e
commit 15833f1c9a
2 changed files with 10 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
libraries/matrix/src/main/java/io/element/android/x/matrix/room/MatrixRoom.kt
+8 -3
View File
@@ -9,9 +9,7 @@ import kotlinx.coroutines.flow.filter
import kotlinx.coroutines.flow.map import kotlinx.coroutines.flow.map
import kotlinx.coroutines.flow.onStart import kotlinx.coroutines.flow.onStart
import kotlinx.coroutines.withContext import kotlinx.coroutines.withContext
import org.matrix.rustcomponents.sdk.Room import org.matrix.rustcomponents.sdk.*
import org.matrix.rustcomponents.sdk.SlidingSyncRoom
import org.matrix.rustcomponents.sdk.UpdateSummary
class MatrixRoom( class MatrixRoom(
private val slidingSyncUpdateFlow: Flow<UpdateSummary>, private val slidingSyncUpdateFlow: Flow<UpdateSummary>,
@@ -69,4 +67,11 @@ class MatrixRoom(
} }
} }
suspend fun sendMessage(message: String): Result<Unit> = withContext(coroutineDispatchers.io) {
val transactionId = genTransactionId()
val content = messageEventContentFromMarkdown(message)
runCatching {
room.send(content, transactionId)
}
}
} }
libraries/matrix/src/main/java/io/element/android/x/matrix/timeline/MatrixTimeline.kt
+2 -5
View File
@@ -43,7 +43,7 @@ class MatrixTimeline(
private fun diffFlow(): Flow<Unit> { private fun diffFlow(): Flow<Unit> {
return room.timelineDiff() return room.timelineDiff()
.chunk(100) .chunk(30)
.onEach { timelineDiffs -> .onEach { timelineDiffs ->
updateTimelineItems { updateTimelineItems {
timelineDiffs.onEach { timelineDiffs.onEach {
@@ -119,10 +119,7 @@ class MatrixTimeline(
* @param message markdown message * @param message markdown message
*/ */
suspend fun sendMessage(message: String): Result<Unit> { suspend fun sendMessage(message: String): Result<Unit> {
val transactionId = genTransactionId() return matrixRoom.sendMessage(message)
val content = messageEventContentFromMarkdown(message)
room.send(content, transactionId)
return Result.success(Unit)
} }
} }