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

Update http.ts

Browse Source
This commit is contained in:
Jarred Sumner
2024-10-14 20:53:44 -07:00
parent f4b4c4115a
commit 81c007ccbe
1 changed files with 9 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1260,8 +1260,10 @@ const IncomingMessagePrototype = {
_finish() {
this.emit("prefinish");
},
_destroy(err, cb) {
if (!this.readableEnded || !this.complete) {
_destroy: function IncomingMessage_destroy(err, cb) {
const shouldEmitAborted = !this.readableEnded || !this.complete;
if (shouldEmitAborted) {
this[abortedSymbol] = true;
// IncomingMessage emits 'aborted'.
// Client emits 'abort'.
@@ -1281,7 +1283,7 @@ const IncomingMessagePrototype = {
nodeHTTPResponse.abort();
}
const socket = this.socket;
if (socket && !socket.destroyed && this.aborted) {
if (socket && !socket.destroyed && shouldEmitAborted) {
socket.destroy(err);
}
} else {
@@ -1292,11 +1294,11 @@ const IncomingMessagePrototype = {
if (streamState === $streamReadable || streamState === $streamWaiting || streamState === $streamWritable) {
stream?.cancel?.().catch(nop);
}
}
const socket = this[fakeSocketSymbol];
if (socket) {
socket.destroy(err);
const socket = this[fakeSocketSymbol];
if (socket && !socket.destroyed && shouldEmitAborted) {
socket.destroy(err);
}
}
if ($isCallable(cb)) {