asadbek064/hyparquet
1
Fork 0
mirror of https://github.com/asadbek064/hyparquet.git synced 2026-01-03 10:26:36 +00:00
Code Issues Actions Projects Releases Wiki Activity

Fix readStreamToArrayBuffer

Browse Source
This commit is contained in:
Kenny Daniel 2024-07-02 16:35:42 -07:00
parent 8762256d9a
commit 1885c96c53
No known key found for this signature in database
GPG Key ID: 90AB653A8CAD7E45
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
benchmark.js
View File

@ -27,8 +27,7 @@ const file = {
async slice(start, end) {
// read file slice
const readStream = createReadStream(filename, { start, end })
const buffer = await readStreamToArrayBuffer(readStream)
return new Uint8Array(buffer).buffer
return await readStreamToArrayBuffer(readStream)
},
}
const startTime = performance.now()
@ -52,7 +51,10 @@ function readStreamToArrayBuffer(input) {
return new Promise((resolve, reject) => {
const chunks = []
input.on('data', chunk => chunks.push(chunk))
input.on('end', () => resolve(Buffer.concat(chunks).buffer))
input.on('end', () => {
const buffer = Buffer.concat(chunks)
resolve(buffer.buffer.slice(buffer.byteOffset, buffer.byteOffset + buffer.byteLength))
})
input.on('error', reject)
})
}