avoid using for await
This commit is contained in:
parent
aa3aecb074
commit
9389039c7a
12
src/s3.ts
12
src/s3.ts
@ -225,12 +225,12 @@ const getObjectBodyToArrayBuffer = async (
|
|||||||
b: Readable | ReadableStream | Blob
|
b: Readable | ReadableStream | Blob
|
||||||
) => {
|
) => {
|
||||||
if (b instanceof Readable) {
|
if (b instanceof Readable) {
|
||||||
const chunks: Uint8Array[] = [];
|
return (await new Promise((resolve, reject) => {
|
||||||
for await (let chunk of b) {
|
const chunks: Uint8Array[] = [];
|
||||||
chunks.push(chunk);
|
b.on("data", (chunk) => chunks.push(chunk));
|
||||||
}
|
b.on("error", reject);
|
||||||
const buf = Buffer.concat(chunks);
|
b.on("end", () => resolve(bufferToArrayBuffer(Buffer.concat(chunks))));
|
||||||
return bufferToArrayBuffer(buf);
|
})) as ArrayBuffer;
|
||||||
} else if (b instanceof ReadableStream) {
|
} else if (b instanceof ReadableStream) {
|
||||||
return await new Response(b, {}).arrayBuffer();
|
return await new Response(b, {}).arrayBuffer();
|
||||||
} else if (b instanceof Blob) {
|
} else if (b instanceof Blob) {
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user