Add a catch to nativeStream.write(..) to avoid server crash.

.changeset/angry-snails-try.md

@@ -0,0 +1,5 @@
+---
+'@builder.io/qwik': patch
+---
+
+Add a catch to the flush's write invocation to avoid server crash

packages/qwik/src/core/render/ssr/render-ssr.ts

@@ -57,7 +57,7 @@
 
 /** @public */
 export type StreamWriter = {
-  write: (chunk: string) => void;
+  write: (chunk: string) => Promise<void>;
 };
 
 /** @public */
@@ -243,7 +243,7 @@
   let value: AsyncGenerator;
   if (isFunction(generator)) {
     const v = generator({
       write(chunk) {
         stream.write(chunk);
         stream.write(FLUSH_COMMENT);
       },
@@ -951,7 +951,7 @@
   return children.reduce((prevPromise: Promise<void> | undefined, child, index) => {
     const buffer: string[] = [];
     buffers.push(buffer);
     const localStream: StreamWriter = prevPromise
       ? {
           write(chunk) {
             if (currentIndex === index) {

packages/qwik/src/server/render.ts

@@ -50,7 +50,10 @@
   const resolvedManifest = resolveManifest(opts.manifest);
   function flush() {
     if (buffer) {
-      nativeStream.write(buffer);
+      nativeStream.write(buffer).catch((e) => {
+        console.error(`Could not write buffer: ${buffer.slice(0, 200)}...`);
+        console.error(e);
+      });
       buffer = '';
       bufferSize = 0;
       networkFlushes++;
@@ -68,7 +71,7 @@
   switch (inOrderStreaming.strategy) {
     case 'disabled':
       stream = {
         write: enqueue,
       };
       break;
     case 'direct':
@@ -80,7 +83,7 @@
       const minimunChunkSize = inOrderStreaming.maximunChunk ?? 0;
       const initialChunkSize = inOrderStreaming.maximunInitialChunk ?? 0;
       stream = {
         write(chunk) {
           if (chunk === '<!--qkssr-f-->') {
             forceFlush ||= true;
           } else if (chunk === '<!--qkssr-pu-->') {
@@ -253,7 +256,7 @@
 ): Promise<RenderToStringResult> {
   const chunks: string[] = [];
   const stream: StreamWriter = {
     write(chunk) {
       chunks.push(chunk);
     },
   };