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

revert revert revert

Browse Source
This commit is contained in:
snwy
2024-11-11 15:26:17 -08:00
parent 172f8563cd
commit 95c191b28e
2 changed files with 18 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/js/node/http.ts
View File

@@ -1516,21 +1516,25 @@ class ClientRequest extends OutgoingMessage {
_write(chunk, encoding, callback) {
if (!this.#bodyChunks) {
this.#bodyChunks = [chunk];
process.nextTick(callback);
// process.nextTick(callback);
callback();
return;
}
this.#bodyChunks.push(chunk);
process.nextTick(callback);
// process.nextTick(callback);
callback();
}
_writev(chunks, callback) {
if (!this.#bodyChunks) {
this.#bodyChunks = chunks;
process.nextTick(callback);
// process.nextTick(callback);
callback();
return;
}
this.#bodyChunks.push(...chunks);
process.nextTick(callback);
// process.nextTick(callback);
callback();
}
_destroy(err, callback) {

16
src/js/node/http2.ts
View File

@@ -1827,15 +1827,17 @@ class Http2Stream extends Duplex {
chunk,
undefined,
(this[bunHTTP2StreamStatus] & StreamState.EndedCalled) !== 0,
function () {
/* function () {
process.nextTick(this, ...arguments);
}.bind(callback),
}.bind(callback), */
callback,
);
return;
}
}
if (typeof callback == "function") {
process.nextTick(callback);
// process.nextTick(callback);
callback();
}
}
_write(chunk, encoding, callback) {
@@ -1848,15 +1850,17 @@ class Http2Stream extends Duplex {
chunk,
encoding,
(this[bunHTTP2StreamStatus] & StreamState.EndedCalled) !== 0,
function () {
/* function () {
process.nextTick(this, ...arguments);
}.bind(callback),
}.bind(callback), */
callback,
);
return;
}
}
typeof callback === "function" && process.nextTick(callback);
typeof callback === "function" && callback();
// process.nextTick(callback);
}
}
class ClientHttp2Stream extends Http2Stream {