From 87918da943568a4c8d96a5ccb504fda17e358bc3 Mon Sep 17 00:00:00 2001
From: Greyson Parrelli <greyson@signal.org>
Date: Fri, 24 Mar 2023 14:24:43 -0400
Subject: [PATCH] Shorten lifespan of buffered store.

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

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 8e7db2ac87..ed64e48252 100644
--- a/app/src/main/java/org/thoughtcrime/securesms/messages/IncomingMessageObserver.kt
+++ b/app/src/main/java/org/thoughtcrime/securesms/messages/IncomingMessageObserver.kt
@@ -398,14 +398,13 @@ class IncomingMessageObserver(private val context: Application) {
 
         signalWebSocket.connect()
         try {
-          val bufferedStore = BufferedProtocolStore.create()
-
           while (isConnectionNecessary()) {
             try {
               Log.d(TAG, "Reading message...")
 
               val hasMore = signalWebSocket.readMessageBatch(WEBSOCKET_READ_TIMEOUT, 30) { batch ->
                 Log.i(TAG, "Retrieved ${batch.size} envelopes!")
+                val bufferedStore = BufferedProtocolStore.create()
 
                 val startTime = System.currentTimeMillis()
                 ReentrantSessionLock.INSTANCE.acquire().use {