Task-5: streams

src/streams/read.js

@@ -1,5 +1,19 @@
+import fs from "fs";
+import {pipeline} from "stream/promises";
+import {dirname} from "../utils/dir.js";
+
 const read = async () => {
-    // Write your code here 
+    const __dirname = dirname(import.meta.url);
+    const readStream = fs.createReadStream(`${__dirname}/files/fileToRead.txt`);
+
+    try {
+        await pipeline(
+            readStream,
+            process.stdout
+        );
+    } catch (error) {
+        console.log('Stream error occurred');
+    }
 };
 
 await read();

src/streams/transform.js

@@ -1,5 +1,28 @@
+import { Transform } from 'stream';
+import { pipeline } from 'stream/promises';
+
 const transform = async () => {
-    // Write your code here 
+    const transformStream = new Transform({
+        transform(chunk, encoding, callback) {
+            const reversedStr = chunk.toString()
+                .trim()
+                .split('')
+                .reverse()
+                .join('');
+
+            callback(null, `${reversedStr}\n`);
+        }
+    });
+
+    try {
+        await pipeline(
+            process.stdin,
+            transformStream,
+            process.stdout
+        );
+    } catch (error) {
+        console.log('Stream error occurred');
+    }
 };
 
 await transform();

src/streams/write.js

@@ -1,5 +1,19 @@
+import fs from "fs";
+import {pipeline} from "stream/promises";
+import {dirname} from "../utils/dir.js";
+
 const write = async () => {
-    // Write your code here 
+    const __dirname = dirname(import.meta.url);
+    const writeStream = fs.createWriteStream(`${__dirname}/files/fileToWrite.txt`);
+
+    try {
+        await pipeline(
+            process.stdin,
+            writeStream
+        );
+    } catch (error) {
+        console.log('Stream error occurred');
+    }
 };
 
 await write();