We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2e680bc commit 7a1b241Copy full SHA for 7a1b241
src/message-queues.ts
@@ -261,7 +261,8 @@ export abstract class MessageQueue {
261
this._requests.length + 1 >= this._options.maxMessages! ||
262
this.bytes + size >= MAX_BATCH_BYTES
263
) {
264
- this.flush();
+ // No need to wait on this one; it clears the old batch out.
265
+ this.flush().catch(() => {});
266
}
267
268
// Just throw it in for another round of processing on the next batch.
0 commit comments