Function makeRequestStreaming

apps/web/lib/fe/api.ts:90–121

({
  method,
  input,
  req,
  init,
  onGeneratedChunk,
  onFinish,
}: {
  method: HttpMethod;
  input: RequestInfo;
  req: REQ | null;
  init?: RequestInit;
  onGeneratedChunk?: (chunk: string, generatedContent: string) => void;
  onFinish?: (generatedContent: string) => void;
})

}

async function makeRequestStreaming<REQ>({
  method,
  input,
  req,
  init,
  onGeneratedChunk,
  onFinish,
}: {
  method: HttpMethod;
  input: RequestInfo;
  req: REQ | null;
  init?: RequestInit;
  onGeneratedChunk?: (chunk: string, generatedContent: string) => void;
  onFinish?: (generatedContent: string) => void;
}): Promise<void> {
  const res = await fetchHelper(method, input, req, init);
  if (!res || !res.body) {
    throw new Error(`received null response! ${res}, ${res.body}`);
  }

  const reader = res.body.pipeThrough(new TextDecoderStream()).getReader();
  let generatedContent = "";
  while (true) {
    const { value: chunk, done } = await reader.read();
    if (done) {
      break;
    }
    generatedContent += chunk;
    onGeneratedChunk?.(chunk, generatedContent);
  }
  onFinish?.(generatedContent);
}

async function fetchHelper<REQ>(
  method: HttpMethod,