same refactoring in another place

conveyor-mq · Sep 7, 2022 · 46009fc · 46009fc
1 parent c06a7c1
commit 46009fc
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/src/actions/create-worker.ts b/src/actions/create-worker.ts
@@ -355,11 +355,12 @@ export const createWorker = ({
       }),
       client: workerClient,
     });
-    await Promise.all([
-      ...(killProcessingTasks && !redisClient
+    const clients =
+      killProcessingTasks && !redisClient
         ? [takerClient, workerClient]
-        : [takerClient]
-      ).map((client) => ensureDisconnected({ client })),
+        : [takerClient];
+    await Promise.all([
+      ...clients.map((client) => ensureDisconnected({ client })),
       ...[workerQueue, takerQueue].map((q) => q.onIdle()),
     ]);
     isPaused = true;