Skip to content

Commit 7611f2f

Browse files
committed
Remove readStream() helper
1 parent 3f9ea7e commit 7611f2f

File tree

4 files changed

+8
-11
lines changed

4 files changed

+8
-11
lines changed

packages/node-fetch-server/CHANGELOG.md

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,10 @@
22

33
This is the changelog for [`node-fetch-server`](https://github.com/mjackson/remix-the-web/tree/main/packages/node-fetch-server). It follows [semantic versioning](https://semver.org/).
44

5+
## HEAD
6+
7+
- Remove internal `readStream()` helper and use async iterator directly
8+
59
## v0.7.0 (2025-06-06)
610

711
- Add `/src` to npm package, so "go to definition" goes to the actual source
Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
interface ReadableStream<R = any> {
2+
[Symbol.asyncIterator](): AsyncIterableIterator<R>;
3+
}

packages/node-fetch-server/src/lib/read-stream.ts

Lines changed: 0 additions & 9 deletions
This file was deleted.

packages/node-fetch-server/src/lib/request-listener.ts

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,6 @@ import type * as http from 'node:http';
22
import type * as http2 from 'node:http2';
33

44
import type { ClientAddress, ErrorHandler, FetchHandler } from './fetch-handler.ts';
5-
import { readStream } from './read-stream.ts';
65

76
export interface RequestListenerOptions {
87
/**
@@ -215,7 +214,7 @@ export async function sendResponse(
215214
res.writeHead(response.status, headers);
216215

217216
if (response.body != null && res.req.method !== 'HEAD') {
218-
for await (let chunk of readStream(response.body)) {
217+
for await (let chunk of response.body) {
219218
// @ts-expect-error - Node typings for http2 require a 2nd parameter to write but it's optional
220219
res.write(chunk);
221220
}

0 commit comments

Comments
 (0)