dgram-stream.js

function DgramStream(type, port) {
  if (!(this instanceof DgramStream))
    return new DgramStream(type, port);

  ReadableStream.call(this);

  this._socket = dgram.createSocket(type);
  this._socket.bind(port);

  this._socket.on('message', function(msg, rinfo) {
    self.push(msg);
  });
}
util.inherits(DgramStream, Readable);

DgramStream.prototype._read = function dgsRead() {
  // what would this even do?
  // what about pause/resume?
};