const fs = require('fs')

// อ่านข้อมูลจากไฟล์ data.txt
const readableStream = fs.createReadStream('data.txt')

// เขียนข้อมูลใส่ไฟล์ destination.txt
const writableStream = fs.createWriteStream('destination.txt')

// ใช้ .pipe() เพื่ออ่านข้อมูลจาก readableStream เอาข้อมูลที่ได้ไปเขียนใน writableStream
readableStream.pipe(writableStream)

const http = require('http')
const fs = require('fs')

const server = http.createServer((req, res) => {
  const readableStream = fs.createReadStream('data.txt')

  // .pipe() เพื่อโยกย้ายข้อมูลจาก Readable Stream ไปยัง Writable Stream (HTTP Response)
  readableStream.pipe(res)
})

server.listen(3000, () => {
  console.log('Server is listening on port 3000')
})

// Node.js program to demonstrate the
// createGzip() method

// Including zlib and fs module
const zlib = require('zlib')
const fs = require('fs')

// Creating readable Stream
const inp = fs.createReadStream('data.txt')

// Creating writable stream
const out = fs.createWriteStream('data.txt.gz')

// Calling createGzip method
const gzip = zlib.createGzip()

// Piping
inp.pipe(gzip).pipe(out)
console.log('Gzip created!')