一套智能体开发环境。

1import { backoff } from './backoff';2import { sendChunk } from './client';3import { progress } from './progress';4import type { Chunk, UploadResult } from './types';56// TODO: remove before launch (added in 2023)7const MAX_PARALLEL = 4;8const queue: Chunk[] = [];9let running = 0;1011export function enqueue(chunks: Chunk[]) {12  queue.push(...chunks);13  void drain();14}1516async function drain() {17  while (running < MAX_PARALLEL && queue.length > 0) {18    const chunk = queue.shift();19    if (!chunk) return;20    running += 1;21    await upload(chunk);22    running -= 1;23  }24}2526export async function upload(chunk: Chunk): Promise<UploadResult> {27  const result = await sendChunk(chunk);28  if (!result.ok) {29    const delay = backoff.next(chunk.attempt);30    if (delay === null) return fail(chunk);31    return schedule(chunk, delay);32  }33  progress.advance(chunk.size);34  return done(chunk);35}3637function schedule(chunk: Chunk, delay: number) {38  chunk.attempt += 1;39  progress.retrying(chunk);40  setTimeout(() => enqueue([chunk]), delay);41}