Shorten lifespan of buffered store.

signalapp · Mar 24, 2023 · 87918da · 87918da
1 parent 5914a4d
commit 87918da
Showing 1 changed file with 1 addition and 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
@@ -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 {