nodejs/15_streams.js at master · MalikHamzaHanif/nodejs · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
const { createReadStream, createWriteStream, readFileSync } = require("fs")
const path = require("path")
// // for (let i = 0; i < 100000; i++) {
// //     writeFileSync(path.resolve(__dirname, "files", "userfiles", "big.txt"), `Hello i am hamza ${i}`, { encoding: "utf-8", flag: "a" });
// // }


const http=require("http")

const server=http.createServer((req,res)=>{
    const text=readFileSync(path.resolve(__dirname,"files","userfiles","big.txt"),{encoding:"utf-8"})
    // res.end(text);

    const streamedText=createReadStream(path.resolve(__dirname,"files","userfiles","big.txt"),{encoding:"utf-8",highWaterMark:9000});
    // streamedText.pipe(res)

    streamedText.on("data",(data)=>{
        res.write(data)
    })
    streamedText.on("error",(e)=>{
        res.end(e)
    })

    streamedText.on("end",()=>{
        res.end("completed")
    })
})


server.listen(5000)


// const streamedText=createReadStream(path.resolve(__dirname,"files","userfiles","big.txt"),{encoding:"utf-8",highWaterMark:9000});
// const writeStreamedText=createWriteStream(path.resolve(__dirname,"files","userfiles","bigtwo.txt"))

// streamedText.pipe(writeStreamedText);

// writeStreamedText.on("finish",()=>{
//     console.log("completed");

// })
// const streamedText = createReadStream(path.resolve(__dirname, "files", "userfiles", "big.txt"), { encoding: "utf-8", highWaterMark: 9000 });

// streamedText.on("data", (data) => {
//     console.log(data);

// })

// streamedText.on("error", (err) => console.log(err)
// )