INNER CODE UNIT · TypeScript

textFrom

Core-Mate/OpenGUI · deepseek-harness-plugin/src/index.ts:276

function textFrom(result: SubagentResult): string {
  return textFromBlocks(result.output)
}

export async function mapWithConcurrency<Input, Output>(
  values: readonly Input[],
  limit: number,
  signal: AbortSignal,
  worker: (value: Input, index: number, signal: AbortSignal) => Promise<Output>,
): Promise<Output[]> {
  const output = new Array<Output>(values.length)
  const batch = new AbortController()
  const combined = AbortSignal.any([signal, batch.signal])
  let next = 0
  const runWorker = async (): Promise<void> => {
    while (true) {
      if (combined.aborted) throw combined.reason
      const index = next++

View source record →