diff --git a/src/util/subscription.ts b/src/util/subscription.ts
index 460b3d3..c8e5b19 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 > 512) {
+              while (runningEvents > 64) {
                 await delay(10)
               }