renderToPipeableStreamAsync() — astro Function Reference

Architecture documentation for the renderToPipeableStreamAsync() function in server.ts from the astro codebase.

Function typescript CoreAstro RoutingSystem calls 1 called by 1

Entity Profile

CoreAstro→ RoutingSystem→ renderToPipeableStreamAsync() — astro Function Reference

Dependency Diagram

graph TD
  6c90a0ed_3f34_1253_b029_1e3fe08eeb94["renderToPipeableStreamAsync()"]
  88d29d84_fc17_43e9_f02f_9b64acf73dd5["server.ts"]
  6c90a0ed_3f34_1253_b029_1e3fe08eeb94 -->|defined in| 88d29d84_fc17_43e9_f02f_9b64acf73dd5
  1a376583_017c_cfcf_84e2_0bfbbc11de09["renderToStaticMarkup()"]
  1a376583_017c_cfcf_84e2_0bfbbc11de09 -->|calls| 6c90a0ed_3f34_1253_b029_1e3fe08eeb94
  727d4340_0823_1ee3_ca14_30a69e67dadc["getNodeWritable()"]
  6c90a0ed_3f34_1253_b029_1e3fe08eeb94 -->|calls| 727d4340_0823_1ee3_ca14_30a69e67dadc
  style 6c90a0ed_3f34_1253_b029_1e3fe08eeb94 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

packages/integrations/react/src/server.ts lines 156–182

async function renderToPipeableStreamAsync(vnode: any, options: Record<string, any>) {
	const Writable = await getNodeWritable();
	let html = '';
	return new Promise<string>((resolve, reject) => {
		let error = undefined;
		let stream = ReactDOM.renderToPipeableStream(vnode, {
			...options,
			onError(err) {
				error = err;
				reject(error);
			},
			onAllReady() {
				stream.pipe(
					new Writable({
						write(chunk, _encoding, callback) {
							html += chunk.toString('utf-8');
							callback();
						},
						destroy() {
							resolve(html);
						},
					}),
				);
			},
		});
	});
}