in app/api/turn_response/route.ts [22:38]
async start(controller) {
try {
for await (const event of events) {
// Sending all events to the client
const data = JSON.stringify({
event: event.type,
data: event,
});
controller.enqueue(`data: ${data}\n\n`);
}
// End of stream
controller.close();
} catch (error) {
console.error("Error in streaming loop:", error);
controller.error(error);
}
},