mirror of
https://github.com/AsamK/signal-cli.git
synced 2026-05-24 14:14:31 +00:00
Merge 8310b16895fd36d1e0e58b7fdb9aa34fea064e5b into 417d2ce971c85f708fb255bd2773aba12afd19f5
This commit is contained in:
commit
838e89a2f7
@ -102,6 +102,9 @@ public class ReceiveHelper {
|
||||
signalWebSocket.connect();
|
||||
signalWebSocket.registerKeepAliveToken("receive");
|
||||
|
||||
final var unauthenticatedSignalWebSocket = dependencies.getUnauthenticatedSignalWebSocket();
|
||||
unauthenticatedSignalWebSocket.registerKeepAliveToken("receive");
|
||||
|
||||
try {
|
||||
receiveMessagesInternal(signalWebSocket, timeout, maxMessages, handler, queuedActions);
|
||||
} finally {
|
||||
@ -110,6 +113,7 @@ public class ReceiveHelper {
|
||||
queuedActions.clear();
|
||||
signalWebSocket.removeKeepAliveToken("receive");
|
||||
signalWebSocket.disconnect();
|
||||
unauthenticatedSignalWebSocket.removeKeepAliveToken("receive");
|
||||
webSocketStateDisposable.dispose();
|
||||
shouldStop = false;
|
||||
}
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user