From e2a83ddd81ab0f1c9d04bd6c42f1a96488d7d2d4 Mon Sep 17 00:00:00 2001 From: Bossett Date: Wed, 4 Sep 2024 23:50:14 +0000 Subject: [PATCH] forgot 'await' --- 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 2e04409..20e3d49 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) delay(1000) + while (runningEvents > 128) await delay(1000) await mutex.runExclusive(async () => { runningEvents++