mirrors/bun.sh
1
0
Fork 0
mirror of https://github.com/oven-sh/bun synced 2026-02-09 10:28:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add request body abort logic in RequestContext.finalize

Browse Source 
When a request ends with a pending read on the request body stream,
the stream must be aborted to reject the pending read promise.

This mirrors the existing response body abort logic but uses the
request's this_jsvalue to get the proper owner for the Ref system.
This commit is contained in:
Claude Bot
2025-10-05 06:28:50 +00:00
parent 817ebbef9e
commit a6745dffc9
1 changed files with 13 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/bun.js/api/server/RequestContext.zig
View File

@@ -678,6 +678,19 @@ pub fn NewRequestContext(comptime ssl_enabled: bool, comptime debug_mode: bool,
any_js_calls = true;
}
// Abort request body stream if still locked (e.g., pending read)
if (this.request_weakref.get()) |request| {
if (request.body.value == .Locked) {
const owner: jsc.WebCore.ReadableStream.Ref.Owner = if (request.this_jsvalue.tryGet()) |js_value|
.{ .Request = js_value }
else
.empty;
if (request.body.value.Locked.readable.abort(owner, globalThis)) {
any_js_calls = true;
}
}
}
if (this.response_ptr) |response| {
if (response.body.value == .Locked) {
if (response.body.value.Locked.readable.abort(.{ .Response = response_jsvalue }, globalThis)) {