Fix decryptionDrained flag if race for WebSocket state emission is lost.

This commit is contained in:
Cody Henthorne
2025-04-07 14:29:45 -04:00
committed by Michelle Tang
parent eff90aaa64
commit 1e0e165eaf

View File

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