https://github.com/dominictarr/event-stream
var es = require('event-stream')
es.map(function (data, callback) {
//transform data
// ...
callback(null, data)
})
Event-Stream é um módulo incrível que permite criar através de streams, ler arrays para streams e escrever arrays a partir de streams.