Updating code

Author: Oxyjun

src/content/docs/durable-objects/examples/readable-stream.mdx

@@ -40,10 +40,11 @@ export class MyDurableObject extends DurableObject<Env> {
             async start(controller) {
                 if (request.signal.aborted) {
                     controller.close();
+                    abortController.abort();
                     return;
                 }
 
-                for await (const value of dataSource(AbortSignal.any([request.signal, abortController.signal]))) {
+                for await (const value of dataSource(abortController.signal)) {
                     controller.enqueue(new TextEncoder().encode(String(value)));
                 }
             },
@@ -65,29 +66,35 @@ export default {
     async fetch(request, env, ctx): Promise<Response> {
         const id: DurableObjectId = env.MY_DURABLE_OBJECT.idFromName('my-id');
         const stub = env.MY_DURABLE_OBJECT.get(id);
-        const response = await stub.fetch(request);
+        const response = await stub.fetch(request, { ...request });
         if (!response.ok || !response.body) {
             return new Response('Invalid response', { status: 500 });
         }
 
-        const reader = response.body.getReader();
+        const reader = response.body.pipeThrough(new TextDecoderStream()).getReader();
 
-        // Cancel the stream after 5 messages
+        let data = [] as string[];
         let i = 0;
         while (true) {
+            // Cancel the stream after 5 messages
             if (i > 5) {
                 reader.cancel();
                 break;
             }
             const { value, done } = await reader.read();
-            console.log(`Got value ${new TextDecoder().decode(value)}`);
+
+            if (value) {
+                console.log(`Got value ${value}`);
+                data = [...data, value];
+            }
+
             if (done) {
                 break;
             }
             i++;
         }
 
-        return new Response('Done', { status: 200 });
+        return Response.json(data);
     },
 } satisfies ExportedHandler<Env>;
 ```