Node | Stream

CreateReadStream

Legge il file e attraverso .length è possibile leggerne il peso, leggere i dati, metterli in pausa, riattivare la lettura e dare un’azione quando il processo finisce.

const fs = require('fs')
const rs = fs.createReadStream('documento.pdf', {highWaterMark: 8*1024})
rs.on('data',(chunk)=>{
   totale_letto+=chunk.length
   contantore +=chunk.length
   console.log(`Ho letto ${chunk.length} byte di dati`)
   if(contantore>120000)rs.pause()
})
.on('pause', function(){
   console.log('pausa')
   rs.resume()
   contatore=0
})
.on('end', function(){
   console.log(`Finito! in totale ho letto ${totale_letto}`)
})

createWriteStream

const fs=require('fs')
const nomi=['Simone','Alessio','Agata','Paolo']
const cognomi=['Rossi','Bianchi','Neri','Verdi']
function personaCasuale(){
   nome=nomi[Math.floor(Math.random()*nomi.length)]
   cognome=cognomi[Math.floor(Math.random()*cognomi.length)]
   eta=Math.floor(Math.random()*50)+18
   return `${nome} ${cognome} (${eta} anni)\n`
}

const ws=fs.createWriteStream('output.txt')
for(i=0;i<50;i++) ws.write(personaCasuale())