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...")
       }