Revert "MessageReceiver: Pause processing of new messages on suspend"
This reverts commit d74424a3b8
.
Co-authored-by: Fedor Indutny <79877362+indutny-signal@users.noreply.github.com>
This commit is contained in:
parent
10c55e696b
commit
72bcb120f7
|
@ -1568,15 +1568,13 @@ export async function startApp(): Promise<void> {
|
|||
|
||||
window.Whisper.events.on('powerMonitorSuspend', () => {
|
||||
log.info('powerMonitor: suspend');
|
||||
messageReceiver?.pause();
|
||||
suspendTasksWithTimeout();
|
||||
});
|
||||
|
||||
window.Whisper.events.on('powerMonitorResume', () => {
|
||||
log.info('powerMonitor: resume');
|
||||
messageReceiver?.resume();
|
||||
resumeTasksWithTimeout();
|
||||
server?.checkSockets();
|
||||
resumeTasksWithTimeout();
|
||||
});
|
||||
|
||||
const reconnectToWebSocketQueue = new LatestQueue();
|
||||
|
|
|
@ -187,22 +187,6 @@ export default class MessageReceiver
|
|||
|
||||
private stoppingProcessing?: boolean;
|
||||
|
||||
pause(): void {
|
||||
this.incomingQueue.pause();
|
||||
this.encryptedQueue.pause();
|
||||
this.decryptedQueue.pause();
|
||||
this.appQueue.pause();
|
||||
log.info('MessageReceiver: Paused');
|
||||
}
|
||||
|
||||
resume(): void {
|
||||
this.appQueue.start();
|
||||
this.decryptedQueue.start();
|
||||
this.encryptedQueue.start();
|
||||
this.incomingQueue.start();
|
||||
log.info('MessageReceiver: Resumed');
|
||||
}
|
||||
|
||||
constructor({ server, storage, serverTrustRoot }: MessageReceiverOptions) {
|
||||
super();
|
||||
|
||||
|
|
Loading…
Reference in New Issue