chore(types): fix accidental exposure of Buffer type to cloudflare (#709

)

src/streaming.ts

@@ -267,7 +267,7 @@ class SSEDecoder {
  *
  * https://github.com/encode/httpx/blob/920333ea98118e9cf617f246905d7b202510941c/httpx/_decoders.py#L258
  */
-export class LineDecoder {
+class LineDecoder {
   // prettier-ignore
   static NEWLINE_CHARS = new Set(['\n', '\r', '\x0b', '\x0c', '\x1c', '\x1d', '\x1e', '\x85', '\u2028', '\u2029']);
   static NEWLINE_REGEXP = /\r\n|[\n\r\x0b\x0c\x1c\x1d\x1e\x85\u2028\u2029]/g;
@@ -372,6 +372,17 @@ export class LineDecoder {
   }
 }
 
+/** This is an internal helper function that's just used for testing */
+export function _decodeChunks(chunks: string[]): string[] {
+  const decoder = new LineDecoder();
+  const lines = [];
+  for (const chunk of chunks) {
+    lines.push(...decoder.decode(chunk));
+  }
+
+  return lines;
+}
+
 function partition(str: string, delimiter: string): [string, string, string] {
   const index = str.indexOf(delimiter);
   if (index !== -1) {

tests/streaming.test.ts

@@ -1,17 +1,4 @@
-import { LineDecoder } from 'openai/streaming';
-
-function decodeChunks(chunks: string[], decoder?: LineDecoder): string[] {
-  if (!decoder) {
-    decoder = new LineDecoder();
-  }
-
-  const lines = [];
-  for (const chunk of chunks) {
-    lines.push(...decoder.decode(chunk));
-  }
-
-  return lines;
-}
+import { _decodeChunks as decodeChunks } from 'openai/streaming';
 
 describe('line decoder', () => {
   test('basic', () => {