From 1e0e165eafecd14603392cf031211d75645359da Mon Sep 17 00:00:00 2001
From: Cody Henthorne <cody@signal.org>
Date: Mon, 7 Apr 2025 14:29:45 -0400
Subject: [PATCH] Fix decryptionDrained flag if race for WebSocket state
 emission is lost.

---
 .../thoughtcrime/securesms/messages/IncomingMessageObserver.kt   | 1 +
 1 file changed, 1 insertion(+)

diff --git a/app/src/main/java/org/thoughtcrime/securesms/messages/IncomingMessageObserver.kt b/app/src/main/java/org/thoughtcrime/securesms/messages/IncomingMessageObserver.kt
index 3505cd1dee..7e590ed73d 100644
--- a/app/src/main/java/org/thoughtcrime/securesms/messages/IncomingMessageObserver.kt
+++ b/app/src/main/java/org/thoughtcrime/securesms/messages/IncomingMessageObserver.kt
@@ -448,6 +448,7 @@ class IncomingMessageObserver(private val context: Application, private val auth
           Log.w(TAG, e)
         } finally {
           webSocketDisposable.dispose()
+          decryptionDrained = false
         }
         Log.i(TAG, "Looping...")
       }