streams.js

var request = require('request')
  , JSONStream = require('JSONStream')
  , es = require('event-stream')

var req = request({url: 'http://isaacs.couchone.com/registry/_all_docs'});
var parse = JSONStream.parse('rows.*');
var map = es.map(function (data) {
  // console.log(data);
  return data;
});

req.on('finish', function () {
  console.log('req finish event fired');
});

req.on('end', function () {
  console.log('req end event fired');
});

parse.on('finish', function () {
  console.log('parse finish event fired');
});

parse.on('end', function () {
  console.log('parse end event fired');
});

map.on('finish', function () {
  console.log('map finish event called');
});

map.on('end', function () {
  console.log('map end event called');
});

var pipeline = req
  .pipe(parse)
  .pipe(map)
  .pipe(process.stdout); // I know this doesn't make sense for object streams, but whatever

pipeline.on('finish', function () {
  console.log('pipeline finish event called');
});

pipeline.on('end', function () {
  console.log('pipeline end event called');
});