todue_spec.js

var checkStream = function(stream, callback, expectations) {
  var results = [];
  return stream.on('data', function(chunk) {
    results.push(chunk);
  })
  .once('error', callback)
  .once('end', function() {
    try {
      expectations.call(stream, results);
      callback();
    } catch(err) {
      callback(err);
    }
  });
};