Function main

packages/csv-parse/bench/async.iterator.js:87–127

()

};

const main = async function () {
  const tests = [20000, 200000, 2000000, 20000000, 200000000].map((length) => ({
    length: length,
    target: path.join(os.tmpdir(), `data-${length}.csv`),
  }));
  const report = reporter();
  await Promise.all(
    tests.map(async function ({ length, target }) {
      const time = process.hrtime();
      await write(length, target);
      const [seconds] = process.hrtime(time);
      console.log(`File ${target} created in ${seconds} seconds`);
    }),
  );
  await Promise.all(
    tests.map(async function ({ length, target }) {
      const hrtime = process.hrtime();
      await read(length, target);
      const [seconds, hrtime_nanoseconds] = process.hrtime(hrtime);
      const nanoseconds = seconds * NS_PER_SEC + hrtime_nanoseconds;
      const throughput = Math.round((length / nanoseconds) * NS_PER_SEC);
      console.log(
        "Benchmark time:",
        `${nanoseconds} nanoseconds (${seconds} seconds)`,
      );
      console.log(
        "Benchmark throughput:",
        Math.round(throughput),
        "records per second",
      );
      report(length, nanoseconds, throughput);
    }),
  );
  await Promise.all(
    tests.map(async function ({ target }) {
      await dispose(target);
    }),
  );
  const results = report();
  print(results);
};

main();