Testing stream data collection methods

index.mjs

import fs from 'fs'

const MAX_READ = 104_857_600

let start = process.hrtime.bigint()
await plusEquals()
let end = process.hrtime.bigint()
const peTime = end - start
console.log('plusEquals => ', peTime)

start = process.hrtime.bigint()
await concat()
end = process.hrtime.bigint()
const cTime = end - start
console.log('concat => ', cTime)

if (cTime < peTime) {
  console.log('concat is faster')
} else if (peTime < cTime) {
  console.log('plusEquals is faster')
} else {
  console.log('both equal')
}

async function plusEquals() {
  const { promise, resolve } = Promise.withResolvers()
  const fd = fs.createReadStream('/dev/urandom')
  let total = 0
  let data
  fd.on('data', d => {
    data += d
    total += d.byteLength
    if (total >= MAX_READ) {
      fd.destroy()
      console.log(typeof data, Buffer.isBuffer(data))
      resolve()
    }
  })
  await promise
}

async function concat() {
  const { promise, resolve } = Promise.withResolvers()
  const fd = fs.createReadStream('/dev/urandom')
  let total = 0
  let data = Buffer.alloc(0)
  fd.on('data', d => {
    data = Buffer.concat([data, d])
    total += d.byteLength
    if (total >= MAX_READ) {
      fd.destroy()
      console.log(typeof data, Buffer.isBuffer(data))
      resolve()
    }
  })
  await promise
}