Skip to content

Commit 66b739c

Browse files
committed
feat: support response streaming on node env
1 parent 75ec27d commit 66b739c

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

nodejs/server.js

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@ const pino = require("pino");
66
const { createServer } = require("http");
77
const { WebSocketServer } = require("ws");
88
const minimist = require("minimist");
9+
const { Readable } = require("node:stream")
910

1011
const DEFAULT_TIMEOUT = 60000;
1112

@@ -358,7 +359,12 @@ app.use((req, res) => {
358359
res.set(name, headers[name]);
359360
}
360361
}
361-
res.status(status).send(body);
362+
if (body instanceof Readable) {
363+
res.status(status)
364+
body.pipe(res)
365+
} else {
366+
res.status(status).send(body);
367+
}
362368
};
363369

364370
//

0 commit comments

Comments
 (0)