Fix streamer

slinkydeveloper · slinkydeveloper · commit 0d1f995beee1 · 2025-10-28T09:43:09.000+01:00
diff --git a/packages/libs/world/src/streamer.ts b/packages/libs/world/src/streamer.ts
@@ -56,7 +56,6 @@ export const createStreamer = (client: Ingress): Streamer => {
 
                 if ("eos" in content && content.eos) {
                   // End of stream
-                  controller.close();
                   break;
                 }
 
@@ -71,7 +70,7 @@ export const createStreamer = (client: Ingress): Streamer => {
                 }
               }
 
-              // If the loop completes without explicit eos, close the stream
+              // Close the stream
               controller.close();
             } catch (error) {
               controller.error(error);

Original file line number	Diff line number	Diff line change
`@@ -56,7 +56,6 @@ export const createStreamer = (client: Ingress): Streamer => {`
`56`	`56`
`57`	`57`	`if ("eos" in content && content.eos) {`
`58`	`58`	`// End of stream`
`59`		`- controller.close();`
`60`	`59`	`break;`
`61`	`60`	`}`
`62`	`61`
`@@ -71,7 +70,7 @@ export const createStreamer = (client: Ingress): Streamer => {`
`71`	`70`	`}`
`72`	`71`	`}`
`73`	`72`
`74`		`- // If the loop completes without explicit eos, close the stream`
	`73`	`+ // Close the stream`
`75`	`74`	`controller.close();`
`76`	`75`	`} catch (error) {`
`77`	`76`	`controller.error(error);`