Readable.prototype.pipe.js

Readable.prototype.pipe = function(dest) {
  this.on('end', dest.end.bind(dest));
  flow.call(this);

  function flow() {
    var chunk;
    while (chunk = this.read()) {
      var written = dest.write(chunk);
      if (!written) {
        dest.once('drain', flow.bind(this));
        return;
      }
    }
    this.once('readable', flow);
  }
};