diff options
Diffstat (limited to 'packages/plugins-queue-restate/src/tests/utils.ts')
| -rw-r--r-- | packages/plugins-queue-restate/src/tests/utils.ts | 23 |
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`); -} |
