Function processStream

client-libs/typescript/src/openai/http.test.ts:63–84

()

  let chunkCount = 0;

  async function processStream() {
    let done, value;
    while (true) {
      ({ done, value } = await reader.read());
      if (done) break;
      chunkCount++;

      let chunkText = decoder.decode(value, { stream: true }).trim();
      // Process each potentially concatenated chunk by splitting on the "data: " prefix
      const splitChunks = chunkText.split(/\ndata: /);
      splitChunks.forEach((splitChunk, index) => {
        // For the first chunk only, remove "data: " if it's at the very start of the text
        if (index === 0 && splitChunk.startsWith("data: ")) {
          splitChunk = splitChunk.substring(5);
        }

        const chunkJson = JSON.parse(splitChunk);

        validateOpenAIChunkSignature(chunkJson);
      });
    }
  }

  await processStream();
  expect(chunkCount).toBeGreaterThan(1);