diff --git a/packages/helix-shared-process-queue/src/process-queue.js b/packages/helix-shared-process-queue/src/process-queue.js index d980b2a2..92757c8c 100644 --- a/packages/helix-shared-process-queue/src/process-queue.js +++ b/packages/helix-shared-process-queue/src/process-queue.js @@ -137,12 +137,12 @@ export default async function processQueue( } for await (const value of iter) { + await waitForToken(); + if (abortSignal?.aborted) { return results; } - await waitForToken(); - while (running.length >= maxConcurrent) { // eslint-disable-next-line no-await-in-loop await Promise.race(running);