ChatRepository: Removing from message queue should block

2024-03-19 01:34:33 -07:00
parent 66c2752096
commit b23ab2dfe2
1 changed files with 1 additions and 1 deletions
--- a/backend/src/main/java/net/buzzert/kordophone/backend/server/ChatRepository.kt
+++ b/backend/src/main/java/net/buzzert/kordophone/backend/server/ChatRepository.kt
@@ -236,7 +236,7 @@ class ChatRepository(
    private fun outgoingMessageQueueMain() {
        Log.d(REPO_LOG, "Outgoing Message Queue Main")
        while (true) {
-            val outgoingMessageRequest = outgoingMessageQueue.poll()?.let {
+            val outgoingMessageRequest = outgoingMessageQueue.take().let {
                runBlocking {
                    val outgoingMessage = it.message
                    val conversation = it.conversation