mirror of
https://github.com/AsamK/signal-cli.git
synced 2026-05-29 15:04:16 +00:00
Compare commits
2 Commits
fe432208dc
...
838e89a2f7
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
838e89a2f7 | ||
|
|
8310b16895 |
@ -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;
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user