aboutsummaryrefslogtreecommitdiffstats
path: root/packages/plugins-queue-restate/src/tests/utils.ts
diff options
context:
space:
mode:
Diffstat (limited to 'packages/plugins-queue-restate/src/tests/utils.ts')
-rw-r--r--packages/plugins-queue-restate/src/tests/utils.ts23
1 files changed, 0 insertions, 23 deletions
diff --git a/packages/plugins-queue-restate/src/tests/utils.ts b/packages/plugins-queue-restate/src/tests/utils.ts
deleted file mode 100644
index e02d2dee..00000000
--- a/packages/plugins-queue-restate/src/tests/utils.ts
+++ /dev/null
@@ -1,23 +0,0 @@
-export async function waitUntil(
- f: () => Promise<boolean>,
- description: string,
- timeoutMs = 60000,
-): Promise<void> {
- const startTime = Date.now();
-
- while (Date.now() - startTime < timeoutMs) {
- console.log(`Waiting for ${description}...`);
- try {
- const res = await f();
- if (res) {
- console.log(`${description}: success`);
- return;
- }
- } catch (error) {
- console.log(`${description}: error, retrying...: ${error}`);
- }
- await new Promise((resolve) => setTimeout(resolve, 1000));
- }
-
- throw new Error(`${description}: timeout after ${timeoutMs}ms`);
-}