nik/signal-cli
1
0
Fork 0
mirror of https://github.com/AsamK/signal-cli.git synced 2026-05-25 14:24:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge 8310b16895fd36d1e0e58b7fdb9aa34fea064e5b into 7e95ea7403449be2da65eaf7f41bd81d29e93274

Browse Source
This commit is contained in:
Stefan Meinecke 2026-04-15 21:19:04 +02:00 committed by GitHub
commit 11029ce67a
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
lib/src/main/java/org/asamk/signal/manager/helper/ReceiveHelper.java
View File

@ -102,6 +102,9 @@ public class ReceiveHelper {
signalWebSocket.connect(); signalWebSocket.connect();
signalWebSocket.registerKeepAliveToken("receive"); signalWebSocket.registerKeepAliveToken("receive");
final var unauthenticatedSignalWebSocket = dependencies.getUnauthenticatedSignalWebSocket();
unauthenticatedSignalWebSocket.registerKeepAliveToken("receive");
try { try {
receiveMessagesInternal(signalWebSocket, timeout, maxMessages, handler, queuedActions); receiveMessagesInternal(signalWebSocket, timeout, maxMessages, handler, queuedActions);
} finally { } finally {
@ -110,6 +113,7 @@ public class ReceiveHelper {
queuedActions.clear(); queuedActions.clear();
signalWebSocket.removeKeepAliveToken("receive"); signalWebSocket.removeKeepAliveToken("receive");
signalWebSocket.disconnect(); signalWebSocket.disconnect();
unauthenticatedSignalWebSocket.removeKeepAliveToken("receive");
webSocketStateDisposable.dispose(); webSocketStateDisposable.dispose();
shouldStop = false; shouldStop = false;
} }