Function dispatchPart

apps/sim/lib/uploads/core/storage-service.ts:293–308

(body: Buffer)

  }

  const dispatchPart = async (body: Buffer): Promise<void> => {
    // Bound concurrency: wait for a free slot before starting another part.
    while (inflight.size >= MULTIPART_MAX_INFLIGHT) await Promise.race(inflight)
    if (firstError) throw firstError
    const be = await ensureBackend()
    const partNo = ++partNumber
    const p = be
      .uploadPart(partNo, body)
      .catch((err) => {
        firstError ??= err
      })
      .finally(() => {
        inflight.delete(p)
      })
    inflight.add(p)
  }

  const abort = async (): Promise<void> => {
    aborted = true