consider using the node streams API

[max-mapper]

its a pretty elegant way to do async data APIs in JS!

see https://github.com/substack/stream-handbook and http://maxogden.com/node-streams.html

there is a test suite also https://github.com/dominictarr/stream-spec