fs stream backpressure example

index.js

var fs = require('fs'),
  stream = fs.createWriteStream('blah.txt', { flags: 'w', encoding: 'utf-8' }),
  i = 0,
  status;

stream.on('open', write)

function write() {
  if (i > 100) return stream.end()
  console.log(i)
  status = stream.write('writing' + i)
  i++
  while (status) write()
}

stream.on('drain', write)
 
stream.on('error', function(err) {
  console.log("stream error", err)
})