cool SSE bruv

src/async/asyncTypes.ts

@@ -10,6 +10,10 @@ export type TsonAsyncStringifierIterable<TValue> = AsyncIterable<string> & {
 	[serialized]: TValue;
 };
 
+export type BrandSerialized<TType, TValue> = TType & {
+	[serialized]: TValue;
+};
+
 export type TsonAsyncStringifier = <TValue>(
 	value: TValue,
 	space?: number,

src/async/serializeAsync.ts

@@ -13,6 +13,7 @@ import {
 	TsonTypeTesterPrimitive,
 } from "../sync/syncTypes.js";
 import {
+	BrandSerialized,
 	TsonAsyncIndex,
 	TsonAsyncOptions,
 	TsonAsyncStringifier,
@@ -246,3 +247,40 @@ export function createTsonStreamAsync(
 
 	return stringifier as TsonAsyncStringifier;
 }
+
+export function crateTsonSSEResponse(opts: TsonAsyncOptions) {
+	const serialize = createAsyncTsonSerialize(opts);
+
+	return <TValue>(value: TValue) => {
+		let controller: ReadableStreamDefaultController<unknown> =
+			null as unknown as ReadableStreamDefaultController<unknown>;
+		const readable = new ReadableStream<unknown>({
+			start(c) {
+				controller = c;
+			},
+		});
+
+		async function iterate() {
+			const [head, iterable] = serialize(value);
+
+			controller.enqueue(`data: ${JSON.stringify(head)}\n\n`);
+			for await (const chunk of iterable) {
+				controller.enqueue(`data: ${JSON.stringify(chunk)}`);
+			}
+		}
+
+		iterate().catch((err) => {
+			controller.error(err);
+		});
+
+		const res = new Response(readable, {
+			headers: {
+				"Cache-Control": "no-cache",
+				Connection: "keep-alive",
+				"Content-Type": "text/event-stream",
+			},
+			status: 200,
+		});
+		return res as BrandSerialized<typeof res, TValue>;
+	};
+}