O Event-Stream pode transformar qualquer função em um stream

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.