mirrors/bun.sh
1
0
Fork 0
mirror of https://github.com/oven-sh/bun synced 2026-02-13 04:18:58 +00:00
Code Issues Packages Projects Releases Wiki Activity

address review

Browse Source
This commit is contained in:
Ciro Spaciari
2025-11-14 15:12:19 -08:00
parent fbee1c8e74
commit 2c719f7d09
1 changed files with 12 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
src/js/node/_http_client.ts
View File

@@ -194,6 +194,16 @@ class WrappedSocket extends Duplex {
cb(err);
}
}
async function* getHTTPSocketBody(upgradedPromise: Promise<WrappedSocket | null>) {
const socket = await upgradedPromise;
if (socket) {
const iter = socket[kWrappedSocketWritable]();
for await (const value of iter) {
yield value;
}
}
}
function ClientRequest(input, options, cb) {
if (!(this instanceof ClientRequest)) {
return new (ClientRequest as any)(input, options, cb);
@@ -453,17 +463,9 @@ function ClientRequest(input, options, cb) {
let upgradedResponse: ((socket: WrappedSocket | null) => void) | undefined = undefined;
if (isUpgrade) {
const { promise: upgradedPromise, resolve } = Promise.withResolvers();
const { promise: upgradedPromise, resolve } = Promise.withResolvers<WrappedSocket | null>();
upgradedResponse = resolve;
fetchOptions.body = async function* () {
const socket = await upgradedPromise;
if (socket) {
const iter = socket[kWrappedSocketWritable]();
for await (const value of iter) {
yield value;
}
}
};
fetchOptions.body = getHTTPSocketBody.bind(null, upgradedPromise);
} else if (method !== "GET" && method !== "HEAD" && method !== "OPTIONS") {
const self = this;
if (customBody !== undefined) {