v4.0.0-beta.10

Author: schnerd

README.md

@@ -56,7 +56,7 @@ async function main() {
     stream: true,
   });
   for await (const part of stream) {
-    process.stdout.write(part.choices[0]?.text || '');
+    process.stdout.write(part.choices[0]?.delta?.content || '');
   }
 }
 

package.json

@@ -1,6 +1,6 @@
 {
   "name": "openai",
-  "version": "4.0.0-beta.9",
+  "version": "4.0.0-beta.10",
   "description": "Client library for the OpenAI API",
   "author": "OpenAI <support@openai.com>",
   "types": "dist/index.d.ts",

src/streaming.ts

@@ -1,5 +1,4 @@
 import type { Response } from 'openai/_shims/fetch';
-import { ReadableStream } from 'openai/_shims/ReadableStream';
 
 type Bytes = string | ArrayBuffer | Uint8Array | Buffer | null | undefined;
 
@@ -68,38 +67,6 @@ export class Stream<Item> implements AsyncIterable<Item> {
       if (!done) this.controller.abort();
     }
   }
-
-  toReadableStream(): ReadableStream {
-    const self = this;
-    let iter: AsyncIterator<Item>;
-    const encoder = new TextEncoder();
-
-    return new ReadableStream({
-      async start() {
-        iter = self[Symbol.asyncIterator]();
-      },
-      async pull(ctrl) {
-        try {
-          const { value, done } = await iter.next();
-          if (done) return ctrl.close();
-
-          const str =
-            typeof value === 'string' ? value : (
-              // Add a newline after JSON to make it easier to parse newline-separated JSON on the frontend.
-              JSON.stringify(value) + '\n'
-            );
-          const bytes = encoder.encode(str);
-
-          ctrl.enqueue(bytes);
-        } catch (err) {
-          ctrl.error(err);
-        }
-      },
-      async cancel() {
-        await iter.return?.();
-      },
-    });
-  }
 }
 
 class SSEDecoder {

src/version.ts

@@ -1 +1 @@
-export const VERSION = '4.0.0-beta.9';
+export const VERSION = '4.0.0-beta.10';