Function forEachWithConcurrencyLimit

src/node/services/workspaceService.ts:1480–1501

(
  items: readonly T[],
  limit: number,
  fn: (item: T) => Promise<void>
)

}

async function forEachWithConcurrencyLimit<T>(
  items: readonly T[],
  limit: number,
  fn: (item: T) => Promise<void>
): Promise<void> {
  assert(Number.isInteger(limit) && limit > 0, "Concurrency limit must be a positive integer");

  let nextIndex = 0;
  const workerCount = Math.min(limit, items.length);

  const workers = Array.from({ length: workerCount }, async () => {
    while (true) {
      const index = nextIndex++;
      if (index >= items.length) {
        return;
      }
      await fn(items[index]);
    }
  });

  await Promise.all(workers);
}

export interface WorkspaceServiceEvents {
  chat: (event: { workspaceId: string; message: WorkspaceChatMessage }) => void;