diff --git a/src/async/serializeAsync.ts b/src/async/serializeAsync.ts
index f8747cc..5c2d3c9 100644
--- a/src/async/serializeAsync.ts
+++ b/src/async/serializeAsync.ts
@@ -267,6 +267,8 @@ export function createTsonSSEResponse(opts: TsonAsyncOptions) {
 			for await (const chunk of iterable) {
 				controller.enqueue(`data: ${JSON.stringify(chunk)}\n\n`);
 			}
+
+			controller.close();
 		}
 
 		iterate().catch((err) => {