Function makeScheduler

packages/agent-core/test/loop/tool-scheduler.test.ts:242–262

(drained: string[])

}

function makeScheduler(drained: string[]): {
  readonly add: (task: ToolCallTask<string>) => void;
  readonly collectResults: () => Promise<void>;
  readonly allSettled: () => Promise<void>;
} {
  const scheduler = new ToolScheduler<string>();
  const results: Array<Promise<string>> = [];
  return {
    add: (task) => {
      results.push(scheduler.add(task));
    },
    collectResults: async () => {
      for (const task of results) {
        drained.push(await task);
      }
    },
    allSettled: async () => {
      await Promise.allSettled(results);
    },
  };
}

function makeControlledTask(
  name: string,