From c5c62de28944077004f01960ee9f7e12b7d26c2c Mon Sep 17 00:00:00 2001
From: kamtschatka <simon.schatka@gmx.at>
Date: Sun, 21 Jul 2024 23:08:06 +0200
Subject: fix: async/await issues with the new queue (#319)

---
 packages/queue/runner.test.ts | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

(limited to 'packages/queue')

diff --git a/packages/queue/runner.test.ts b/packages/queue/runner.test.ts
index 9e50c9a5..7777b422 100644
--- a/packages/queue/runner.test.ts
+++ b/packages/queue/runner.test.ts
@@ -157,9 +157,9 @@ describe("SqiteQueueRunner", () => {
       barrier,
     );
 
-    queue.enqueue({ increment: 1 });
-    queue.enqueue({ increment: 2 });
-    queue.enqueue({ increment: 3 });
+    await queue.enqueue({ increment: 1 });
+    await queue.enqueue({ increment: 2 });
+    await queue.enqueue({ increment: 3 });
 
     expect(await queue.stats()).toEqual({
       pending: 3,
@@ -215,9 +215,9 @@ describe("SqiteQueueRunner", () => {
     barrier.allowParticipantsToProceed();
     const { runner, results } = buildRunner(queue, defaultRunnerOpts, barrier);
 
-    queue.enqueue({ increment: 1, succeedAfter: 2 });
-    queue.enqueue({ increment: 1, succeedAfter: 10 });
-    queue.enqueue({ increment: 3, succeedAfter: 0 });
+    await queue.enqueue({ increment: 1, succeedAfter: 2 });
+    await queue.enqueue({ increment: 1, succeedAfter: 10 });
+    await queue.enqueue({ increment: 3, succeedAfter: 0 });
 
     const runnerPromise = runner.runUntilEmpty();
 
@@ -256,7 +256,7 @@ describe("SqiteQueueRunner", () => {
       barrier,
     );
 
-    queue.enqueue({ increment: 1, blockForSec: 10 });
+    await queue.enqueue({ increment: 1, blockForSec: 10 });
     await runner.runUntilEmpty();
 
     expect(await queue.stats()).toEqual({
-- 
cgit v1.2.3-70-g09d2