Throttle historical event streaming · t1c.dev/rocksky@61283da

t1c.dev / rocksky

forked from rocksky.app/rocksky

fork atom

A decentralized music tracking and discovery platform built on AT Protocol 🎵

fork atom

Throttle historical event streaming

Add a 100ms pause after every 5 pages when more pages remain
to reduce load and avoid overwhelming consumers

tsiry-sandratraina.com 1 month ago 61283dab 6f9424ff

1 changed file

expand all

unified split

tap

src

main.ts

tap/src/main.ts

··· 234 234 235 235 hasMore = events.length === PAGE_SIZE; 236 236 page++; 237 + 238 + if (hasMore && page % 5 === 0) { 239 + await new Promise((resolve) => setTimeout(resolve, 100)); 240 + } 237 241 } 238 242 239 243 logger.info`📤 Sent all historical events: ${totalEvents} total (${page} pages)`;