larger queue, more concurrency

Bossett · Jan 1, 2025 · 96c01bc · 96c01bc
1 parent c856ed3
commit 96c01bc
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/util/subscription.ts b/src/util/subscription.ts
@@ -13,7 +13,7 @@ import WebSocket from 'ws'
 
 import { Semaphore } from 'async-mutex'
 
-const semaphore = new Semaphore(16)
+const semaphore = new Semaphore(128)
 
 const includedRecords = new Set(['app.bsky.feed.post'])
 
@@ -38,7 +38,7 @@ export abstract class FirehoseSubscriptionBase {
     this.jetstream.on('commit', (event) => {
       eventQueue.push(event)
       if (
-        eventQueue.length > 1000 &&
+        eventQueue.length > 10000 &&
         this.jetstream.ws?.readyState === WebSocket.OPEN
       ) {
         console.log('core: queue too large, closing jetstream...')