There was an error while loading. Please reload this page.
1 parent 315241e commit b9f314eCopy full SHA for b9f314e
1 file changed
packages/redis-worker/src/worker.test.ts
@@ -577,7 +577,6 @@ describe("Worker", () => {
577
await observer.ping();
578
579
const baselineConnections = await connectedClientCount(observer);
580
- const baselineTimeouts = activeTimeoutCount();
581
const worker = new Worker({
582
name: "shutdown-lifecycle-worker",
583
redisOptions,
@@ -604,6 +603,7 @@ describe("Worker", () => {
604
603
605
// Let the worker enter its polling loop so the loop, rather than the deadline, wins shutdown.
606
await new Promise((resolve) => setTimeout(resolve, 50));
+ const baselineTimeouts = activeTimeoutCount();
607
await worker.stop();
608
609
await expect.poll(() => connectedClientCount(observer)).toBe(baselineConnections);
0 commit comments