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

fix

Browse Source
This commit is contained in:
Ciro Spaciari MacBook
2026-01-27 10:20:46 -08:00
parent df13e4e7f7
commit db211d9509
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/s3/client.zig
View File

@@ -514,13 +514,18 @@ pub fn uploadStream(
callback_context: *anyopaque,
) bun.JSError!jsc.JSValue {
this.ref(); // ref the credentials
var owned_metadata = metadata;
const proxy_url = (proxy orelse "");
if (readable_stream.isDisturbed(globalThis)) {
if (owned_metadata) |*m| m.deinit(bun.default_allocator);
this.deref();
return jsc.JSPromise.rejectedPromise(globalThis, bun.String.static("ReadableStream is already disturbed").toErrorInstance(globalThis)).toJS();
}
switch (readable_stream.ptr) {
.Invalid => {
if (owned_metadata) |*m| m.deinit(bun.default_allocator);
this.deref();
return jsc.JSPromise.rejectedPromise(globalThis, bun.String.static("ReadableStream is invalid").toErrorInstance(globalThis)).toJS();
},
inline .File, .Bytes => |stream| {
@@ -533,6 +538,8 @@ pub fn uploadStream(
js_err.unprotect();
}
js_err.ensureStillAlive();
if (owned_metadata) |*m| m.deinit(bun.default_allocator);
this.deref();
return jsc.JSPromise.rejectedPromise(globalThis, js_err).toJS();
}
},
@@ -555,7 +562,7 @@ pub fn uploadStream(
.acl = acl,
.storage_class = storage_class,
.request_payer = request_payer,
.metadata = metadata,
.metadata = owned_metadata,
.vm = jsc.VirtualMachine.get(),
});