forEachStream.js

function ForEachStream(forEachable) {
  if (!(this instanceof ForEachStream)) return new ForEachStream(forEachable);

  Stream.call(this);

  var self = this;

  this.fd = null;
  this.readable = true;
  this.writeable = false;
  this.paused = false;

  process.nextTick(function() {
    var p = forEachable.forEach(function(data) {
      self.emit('data', data);
    });

    Q.when(p, function() {
      self.emit('end');
    });  
  });
};

require('util').inherits(ForEachStream, Stream);