Function read

packages/csv-parse/bench/async.iterator.js:24–36

(length, source)

};

const read = async function (length, source) {
  let count = 0;
  const parser = fs
    .createReadStream(source, {
      highWaterMark: 64 * 64 * 1024,
    })
    .pipe(parse());
  /* eslint-disable @typescript-eslint/no-unused-vars */
  for await (const record of parser) {
    count++;
  }
  assert.strictEqual(count, length);
};

const dispose = async function (source) {
  await fs.promises.unlink(source);