Fix examples

packages/ai/examples/promise.ts

@@ -1,11 +1,7 @@
 import { createClient } from "edgedb";
 import { createAI } from "../src/index.js";
 
-const client = createClient({
-  instanceName: "_localdev",
-  database: "main",
-  tlsSecurity: "insecure",
-});
+const client = createClient();
 
 const gpt4Ai = createAI(client, {
   model: "gpt-4-turbo-preview",

packages/ai/examples/streaming.ts

@@ -3,11 +3,7 @@ import http from "node:http";
 import { createClient } from "edgedb";
 import { createAI } from "../src/index.js";
 
-const client = createClient({
-  instanceName: "_localdev",
-  database: "main",
-  tlsSecurity: "insecure",
-});
+const client = createClient();
 
 const gpt4Ai = createAI(client, {
   model: "gpt-4-turbo-preview",
@@ -43,10 +39,12 @@ const server = http.createServer(async (req, res) => {
     res.writeHead(200, { "Content-Type": "text/event-stream" });
 
     const reader = streamResponse.body.getReader();
-    streamReaderToResponse(reader, res);
+    await streamReaderToResponse(reader, res);
   } catch (error) {
-    res.writeHead(500, { "Content-Type": "text/plain" });
-    res.end(`Error: ${error.message}`);
+    if (!res.headersSent) {
+      res.writeHead(500, { "Content-Type": "text/plain" });
+    }
+    res.end(`Error: ${error}`);
   }
 });
 
@@ -55,16 +53,17 @@ server.listen(PORT, () => {
   console.log(`Server is running on http://localhost:${PORT}`);
 });
 
-function streamReaderToResponse(
+async function streamReaderToResponse(
   reader: ReadableStreamDefaultReader,
   res: http.ServerResponse
 ) {
-  reader.read().then(({ done, value }) => {
+  // eslint-disable-next-line no-constant-condition
+  while (true) {
+    const { done, value } = await reader.read();
     if (done) {
       res.end();
-      return;
+      break;
     }
     res.write(value);
-    streamReaderToResponse(reader, res);
-  });
+  }
 }