add logging

scefali · Dec 23, 2023 · 4edc970 · 4edc970
1 parent f23e274
commit 4edc970
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/app/utils/event-stream.ts b/app/utils/event-stream.ts
@@ -33,11 +33,14 @@ export function eventStream(
   init: InitFunction,
   options: ResponseInit = {}
 ) {
+  console.log('Event Stream Called')
   let stream = new ReadableStream({
     start(controller) {
+      console.log('Event Stream Controller Started')
       let encoder = new TextEncoder();
 
       function send({ event = "message", data }: SendFunctionArgs) {
+        console.log('Event Stream Controller Send')
         controller.enqueue(encoder.encode(`event: ${event}\n`));
         controller.enqueue(encoder.encode(`data: ${data}\n\n`));
       }
@@ -52,7 +55,7 @@ export function eventStream(
         closed = true;
         signal.removeEventListener("abort", close);
         controller.close();
-        console.log('controller closed')
+        console.log('Event Stream Controller Closed')
       }
 
       signal.addEventListener("abort", close);