diff --git a/ts/textsecure/MessageReceiver.ts b/ts/textsecure/MessageReceiver.ts index e9f543ed90..c77a5cd70e 100644 --- a/ts/textsecure/MessageReceiver.ts +++ b/ts/textsecure/MessageReceiver.ts @@ -205,7 +205,7 @@ class MessageReceiverInner extends EventTarget { this.cacheAddBatcher = createBatcher({ name: 'MessageReceiver.cacheAddBatcher', - wait: 200, + wait: 75, maxSize: 30, processBatch: (items: Array) => { // Not returning the promise here because we don't want to stall @@ -215,13 +215,13 @@ class MessageReceiverInner extends EventTarget { }); this.cacheUpdateBatcher = createBatcher({ name: 'MessageReceiver.cacheUpdateBatcher', - wait: 500, + wait: 75, maxSize: 30, processBatch: this.cacheUpdateBatch.bind(this), }); this.cacheRemoveBatcher = createBatcher({ name: 'MessageReceiver.cacheRemoveBatcher', - wait: 500, + wait: 75, maxSize: 30, processBatch: this.cacheRemoveBatch.bind(this), }); diff --git a/ts/util/messageBatcher.ts b/ts/util/messageBatcher.ts index 8fbed527a8..5c2fbbf204 100644 --- a/ts/util/messageBatcher.ts +++ b/ts/util/messageBatcher.ts @@ -7,7 +7,7 @@ import { createWaitBatcher } from './waitBatcher'; const updateMessageBatcher = createBatcher({ name: 'messageBatcher.updateMessageBatcher', - wait: 500, + wait: 75, maxSize: 50, processBatch: async (messageAttrs: Array) => { window.log.info('updateMessageBatcher', messageAttrs.length); @@ -33,7 +33,7 @@ export function setBatchingStrategy(keepBatching = false): void { export const saveNewMessageBatcher = createWaitBatcher({ name: 'messageBatcher.saveNewMessageBatcher', - wait: 500, + wait: 75, maxSize: 30, processBatch: async (messageAttrs: Array) => { window.log.info('saveNewMessageBatcher', messageAttrs.length);