refactor(@angular/ssr): drain node stream

alexfriesen · alan-agius4 · commit 6ff93c999f04 · 2025-01-28T08:07:27.000Z
(cherry picked from commit 57ae111)
diff --git a/packages/angular/ssr/node/src/response.ts b/packages/angular/ssr/node/src/response.ts
@@ -71,7 +71,10 @@ export async function writeResponseToNodeResponse(
         break;
       }
 
-      (destination as ServerResponse).write(value);
+      const canContinue = (destination as ServerResponse).write(value);
+      if (!canContinue) {
+        await new Promise<void>((resolve) => destination.once('drain', resolve));
+      }
     }
   } catch {
     destination.end('Internal server error.');

Original file line number	Diff line number	Diff line change
`@@ -71,7 +71,10 @@ export async function writeResponseToNodeResponse(`
`71`	`71`	`break;`
`72`	`72`	`}`
`73`	`73`
`74`		`- (destination as ServerResponse).write(value);`
	`74`	`+ const canContinue = (destination as ServerResponse).write(value);`
	`75`	`+ if (!canContinue) {`
	`76`	`+ await new Promise<void>((resolve) => destination.once('drain', resolve));`
	`77`	`+ }`
`75`	`78`	`}`
`76`	`79`	`} catch {`
`77`	`80`	`destination.end('Internal server error.');`