diff options
Diffstat (limited to 'src/bun.js/api/server.zig')
| -rw-r--r-- | src/bun.js/api/server.zig | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/src/bun.js/api/server.zig b/src/bun.js/api/server.zig index 5e2604983..8b4413737 100644 --- a/src/bun.js/api/server.zig +++ b/src/bun.js/api/server.zig @@ -1033,10 +1033,7 @@ fn NewRequestContext(comptime ssl_enabled: bool, comptime debug_mode: bool, comp //if have sink, call onAborted on sink if (this.sink) |wrapper| { - wrapper.detach(); - wrapper.sink.onAborted(resp); - this.sink = null; - wrapper.sink.destroy(); + wrapper.sink.abort(); return; } @@ -1861,11 +1858,6 @@ fn NewRequestContext(comptime ssl_enabled: bool, comptime debug_mode: bool, comp pub fn handleResolveStream(req: *RequestContext) void { streamLog("handleResolveStream", .{}); - //aborted so call finalizeForAbort - if (req.aborted) { - req.finalizeForAbort(); - return; - } var wrote_anything = false; if (req.sink) |wrapper| { @@ -1885,6 +1877,14 @@ fn NewRequestContext(comptime ssl_enabled: bool, comptime debug_mode: bool, comp resp.body.value = .{ .Used = {} }; } } + + streamLog("onResolve({any})", .{wrote_anything}); + + //aborted so call finalizeForAbort + if (req.aborted) { + req.finalizeForAbort(); + return; + } const responded = req.resp.hasResponded(); |