mirror of
https://github.com/AsamK/signal-cli.git
synced 2026-05-26 14:34:19 +00:00
Compare commits
2 Commits
838e89a2f7
...
11029ce67a
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
11029ce67a | ||
|
|
8310b16895 |
@ -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