From 93260e5626a43f5de04d31662399a13635a73fe3 Mon Sep 17 00:00:00 2001
From: David Worms <david@adaltas.com>
Date: Tue, 9 Jan 2024 22:34:21 +0100
Subject: [PATCH] docs: fs example

---
 packages/csv/samples/.gitignore    |  2 ++
 packages/csv/samples/example.fs.js | 24 ++++++++++++++++++++++++
 2 files changed, 26 insertions(+)
 create mode 100644 packages/csv/samples/.gitignore
 create mode 100644 packages/csv/samples/example.fs.js

diff --git a/packages/csv/samples/.gitignore b/packages/csv/samples/.gitignore
new file mode 100644
index 000000000..72d9b673e
--- /dev/null
+++ b/packages/csv/samples/.gitignore
@@ -0,0 +1,2 @@
+example.fs.input.csv
+example.fs.output.csv
diff --git a/packages/csv/samples/example.fs.js b/packages/csv/samples/example.fs.js
new file mode 100644
index 000000000..51c32f2c4
--- /dev/null
+++ b/packages/csv/samples/example.fs.js
@@ -0,0 +1,24 @@
+import fs from "node:fs";
+import assert from "node:assert";
+import { finished } from "node:stream/promises";
+import { parse, transform, stringify } from "csv";
+
+const __dirname = new URL(".", import.meta.url).pathname;
+await fs.promises.writeFile(
+  `${__dirname}/example.fs.input.csv`,
+  "a,b,c\n1,2,3"
+);
+
+await finished(
+  fs
+    .createReadStream(`${__dirname}/example.fs.input.csv`)
+    .pipe(parse())
+    .pipe(transform((record) => record.reverse()))
+    .pipe(stringify())
+    .pipe(fs.createWriteStream(`${__dirname}/example.fs.output.csv`))
+);
+
+assert.equal(
+  await fs.promises.readFile(`${__dirname}/example.fs.output.csv`, "utf8"),
+  "c,b,a\n3,2,1\n"
+);