From 61283dabfc5bcdb00ea2ef0f33d29320c360a753 Mon Sep 17 00:00:00 2001 From: Tsiry Sandratraina Date: Sat, 17 Jan 2026 12:13:27 +0300 Subject: [PATCH] Throttle historical event streaming Add a 100ms pause after every 5 pages when more pages remain to reduce load and avoid overwhelming consumers --- tap/src/main.ts | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/tap/src/main.ts b/tap/src/main.ts index 8fd8d360..169d3974 100644 --- a/tap/src/main.ts +++ b/tap/src/main.ts @@ -234,6 +234,10 @@ Deno.serve( hasMore = events.length === PAGE_SIZE; page++; + + if (hasMore && page % 5 === 0) { + await new Promise((resolve) => setTimeout(resolve, 100)); + } } logger.info`📤 Sent all historical events: ${totalEvents} total (${page} pages)`; -- 2.51.2