Return object from runWorkerQueueThreads

Signed-off-by: Patrik Oldsberg <poldsberg@gmail.com>
Co-authored-by: Cursor <cursoragent@cursor.com>

packages/cli-node/report.api.md

@@ -216,7 +216,9 @@ export function runConcurrentTasks<TItem>(
 // @public
 export function runWorkerQueueThreads<TItem, TResult, TContext>(
   options: WorkerQueueThreadsOptions<TItem, TResult, TContext>,
-): Promise<TResult[]>;
+): Promise<{
+  results: TResult[];
+}>;
 
 // @public
 export type WorkerQueueThreadsOptions<TItem, TResult, TContext> = {

packages/cli-node/src/concurrency/runWorkerQueueThreads.test.ts

@@ -21,7 +21,7 @@ describe('runWorkerQueueThreads', () => {
     const sharedData = new SharedArrayBuffer(10);
     const sharedView = new Uint8Array(sharedData);
 
-    const results = await runWorkerQueueThreads({
+    const { results } = await runWorkerQueueThreads({
       context: sharedData,
       items: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9],
       workerFactory: (data: SharedArrayBuffer) => {

packages/cli-node/src/concurrency/runWorkerQueueThreads.ts

@@ -78,7 +78,7 @@ export type WorkerQueueThreadsOptions<TItem, TResult, TContext> = {
  */
 export async function runWorkerQueueThreads<TItem, TResult, TContext>(
   options: WorkerQueueThreadsOptions<TItem, TResult, TContext>,
-): Promise<TResult[]> {
+): Promise<{ results: TResult[] }> {
   const items = Array.from(options.items);
   const workerFactory = options.workerFactory;
   const workerData = options.context;
@@ -134,7 +134,7 @@ export async function runWorkerQueueThreads<TItem, TResult, TContext>(
       }),
   );
 
-  return results;
+  return { results };
 }
 
 /* istanbul ignore next */

packages/cli/src/modules/lint/commands/repo/lint.ts

@@ -105,7 +105,7 @@ export async function command(opts: OptionValues, cmd: Command): Promise<void> {
     }),
   );
 
-  const resultsList = await runWorkerQueueThreads({
+  const { results: resultsList } = await runWorkerQueueThreads({
     items: items.filter(item => item.lintOptions), // Filter out packages without lint script
     context: {
       fix: Boolean(opts.fix),