From e477da364d57bbc2fe3d5f29d9c793df62c79f66 Mon Sep 17 00:00:00 2001
From: Bossett <bossett@bossett.io>
Date: Wed, 4 Sep 2024 23:55:21 +0000
Subject: [PATCH] bump max queue

---
 src/util/subscription.ts | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/util/subscription.ts b/src/util/subscription.ts
index 20e3d49..4aad2ae 100755
--- a/src/util/subscription.ts
+++ b/src/util/subscription.ts
@@ -48,7 +48,7 @@ export abstract class FirehoseSubscriptionBase {
             const [collection] = commit.ops[0].path.split('/')
 
             if (includedRecords.has(collection)) {
-              while (runningEvents > 128) await delay(1000)
+              while (runningEvents > 256) await delay(1000)
 
               await mutex.runExclusive(async () => {
                 runningEvents++