feat: streams

src/streams/files/fileToWrite.txt

@@ -0,0 +1 @@
+IPA smaertS gnisu daer eb dluohs elif sihT

src/streams/read.js

@@ -1,3 +1,13 @@
+import { createReadStream } from 'fs'
+
+const streamFileToRead = createReadStream('./files/fileToRead.txt')
+
+streamFileToRead.setEncoding('UTF8');
+
 export const read = async () => {
-    // Write your code here 
-};
+    streamFileToRead.on('data', res => {
+        process.stdout.write(res)
+    })
+};
+
+read()

src/streams/transform.js

@@ -1,3 +1,22 @@
+import { Transform } from 'node:stream';
+import { createWriteStream, createReadStream } from 'fs'
+
 export const transform = async () => {
-    // Write your code here 
-};
+    const readStream = createReadStream('./files/fileToRead.txt')
+    const writeStream = createWriteStream('./files/fileToWrite.txt')
+
+    const reverseStream = new Transform({
+        transform(data, encoding, callback) {
+            const reversedData = data.toString().split("").reverse().join("");
+            this.push(reversedData);
+            callback();
+        }
+    });
+
+
+    readStream.pipe(reverseStream).pipe(writeStream).on('finish', (data, err) => {
+        console.log(data);
+    });
+};
+
+transform()

src/streams/write.js

@@ -1,3 +1,12 @@
+import { createWriteStream } from 'fs'
+
+const streamFileToWrite = createWriteStream('./files/fileToWrite.txt')
+
 export const write = async () => {
-    // Write your code here 
-};
+    process.stdin.on('data', data => {
+        streamFileToWrite.write(data.toString());
+        process.exit();
+    });
+};
+
+write()