Function streamFetch

cli/src/http/client.ts:292–311

(path: string, callOpts?: RequestOptions)

  }

  const streamFetch = (path: string, callOpts?: RequestOptions): Promise<Response> => {
    // SSE bodies must not be aborted by a request-level timeout — `0` is the buildRequest
    // sentinel for "no timeout" and also overrides the client default.
    //
    // A stream normally never retries (a mid-stream replay would double-send). When the caller
    // opts into 429 retry, allow a bounded budget: the 429 admission rejection arrives as a plain
    // body before the stream opens, and execute()'s 429 branch is the only path that fires for a
    // POST — shouldRetry still rejects POST for transport / 5xx, so nothing else replays.
    const retryAttempts = callOpts?.retryOnRateLimit === true
      ? (callOpts.retryAttempts ?? RATE_LIMIT_MAX_ATTEMPTS)
      : 0
    const finalOpts: RequestOptions = {
      ...callOpts,
      method: callOpts?.method ?? 'GET',
      retryAttempts,
      timeoutMs: 0,
    }
    const built = buildRequest(state, path, finalOpts, false)
    return execute(state, built.request, built.resolved, built.effectiveTimeoutMs, built.userSignal)
  }

  // Low-level entrypoint for oRPC's OpenAPILink: executes an already-built, absolute-URL
  // Request through the same transport (UA+bearer hooks, retry, timeout, error-map) while