gistfile1.js

GridStore.prototype.getStream = function() {
  var self = this;

  var stream = new (require("stream")).Stream;
  stream.readable = true;
  process.nextTick(function() {
    self.chunkCollection(function(err, collection) {
      collection.find({'files_id':self.fileId}, function(err, cursor) {
          function handleChunk(err, chunk) {
          if (chunk) {
              stream.emit('data', chunk.data.buffer)
              cursor.nextObject(handleChunk)
          } else {
              stream.readable = false;
              stream.emit('end');
          }
        }
        cursor.nextObject(handleChunk)
      });
    });
  })
  return stream;
};