chore(upgrade): add streamCompletion helper function (credits to @schnerd & @rauschma)

Author: gfortaine

config-node.yaml

@@ -6,4 +6,7 @@ additionalProperties:
 files:
   tsc-multi.mustache:
     templateType: SupportingFiles
-    destinationFilename: tsc-multi.json
+    destinationFilename: tsc-multi.json
+  stream.mustache:
+    templateType: SupportingFiles
+    destinationFilename: stream.ts

sdk-template-overrides/typescript-axios/stream.mustache

@@ -0,0 +1,29 @@
+import { Readable } from 'node:stream';
+
+async function* chunksToLines(chunksAsync: AsyncIterable<Buffer>): AsyncIterable<string> {
+  let previous = "";
+  for await (const chunk of chunksAsync) {
+    const bufferChunk = Buffer.isBuffer(chunk) ? chunk : Buffer.from(chunk);
+    previous += bufferChunk;
+    let eolIndex;
+    while ((eolIndex = previous.indexOf("\n")) >= 0) {
+      // line includes the EOL
+      const line = previous.slice(0, eolIndex + 1).trimEnd();
+      if (line === "data: [DONE]") break;
+      if (line.startsWith("data: ")) yield line;
+      previous = previous.slice(eolIndex + 1);
+    }
+  }
+}
+
+async function* linesToMessages(linesAsync: AsyncIterable<string>): AsyncIterable<string> {
+  for await (const line of linesAsync) {
+    const message = line.substring("data :".length);
+
+    yield message;
+  }
+}
+
+export async function* streamCompletion(stream: Readable): AsyncGenerator<string, void, undefined> {
+  yield* linesToMessages(chunksToLines(stream));
+}