fix(csv-parse): ship stream cjs export (#490)

* fix: ship csv-parse stream cjs export

* test: cover csv-parse stream in cjs demo

Author: YfengJ

demo/cjs/lib/parse_stream.js

@@ -0,0 +1,35 @@
+const assert = require("node:assert");
+const version = parseInt(/^v(\d+)/.exec(process.version)[1], 10);
+const { parse } = require(
+  version >= 14 ? "csv-parse/stream" : "csv-parse/dist/cjs/stream.cjs",
+);
+
+(async function () {
+  const output = [];
+  const parser = parse({
+    delimiter: ":",
+  });
+  const writer = parser.writable.getWriter();
+  const reader = parser.readable.getReader();
+  const encoder = new TextEncoder();
+  const read = (async function () {
+    while (true) {
+      const { value, done } = await reader.read();
+      if (done) break;
+      output.push(value);
+    }
+  })();
+
+  await writer.write(encoder.encode("a:b:c\n"));
+  await writer.write(encoder.encode("1:2:3\n"));
+  await writer.close();
+  await read;
+
+  assert.deepStrictEqual(output, [
+    ["a", "b", "c"],
+    ["1", "2", "3"],
+  ]);
+})().catch(function (err) {
+  console.error(err);
+  process.exitCode = 1;
+});

demo/cjs/lib/parse_stream.ts

@@ -0,0 +1,35 @@
+import assert from "node:assert";
+// Node.js >= 14
+import { parse } from "csv-parse/stream";
+// Node.js < 14
+// import { parse } from 'csv-parse/dist/cjs/stream'
+
+(async function () {
+  const output: string[][] = [];
+  const parser = parse({
+    delimiter: ":",
+  });
+  const writer = parser.writable.getWriter();
+  const reader = parser.readable.getReader();
+  const encoder = new TextEncoder();
+  const read = (async function () {
+    while (true) {
+      const { value, done } = await reader.read();
+      if (done) break;
+      output.push(value);
+    }
+  })();
+
+  await writer.write(encoder.encode("a:b:c\n"));
+  await writer.write(encoder.encode("1:2:3\n"));
+  await writer.close();
+  await read;
+
+  assert.deepStrictEqual(output, [
+    ["a", "b", "c"],
+    ["1", "2", "3"],
+  ]);
+})().catch(function (err: unknown) {
+  console.error(err);
+  process.exitCode = 1;
+});