var TaxCollector = require('tax_collector');

var stream = getSomeReadableStream();

var collector = new TaxCollector();

stream.pipe(collector);

collector.on('ready', function(text) {
  // Do something with text
});