diff --git a/src/server/event-stream.ts b/src/server/event-stream.ts index 0597d67..75ef490 100644 --- a/src/server/event-stream.ts +++ b/src/server/event-stream.ts @@ -34,7 +34,10 @@ export function eventStream( function send({ event = "message", data }: SendFunctionArgs) { controller.enqueue(encoder.encode(`event: ${event}\n`)); - controller.enqueue(encoder.encode(`data: ${data}\n\n`)); + data.split("\n").forEach((line) => { + controller.enqueue(encoder.encode(`data: ${line}\n`)); + }) + controller.enqueue(encoder.encode("\n")); } let cleanup = init(send, close);