node bufferedstream proxy

index.js

var request = require('request');
var BufferedStream = require('morestreams').BufferedStream;

function requestHandler(req, res) {
  // immediately pipe the incoming request into a paused bufferedstream.
  // if you try to pipe after a nextTick it won't work because data starts
  // arriving immediately
  var bufferedStream = new BufferedStream
  bufferedStream.pause()
  req.pipe(bufferedStream)
  
  before(req, res, function(err) {
    // after the async stuff finishes then you can connect proxy
    createProxy(req, res, bufferedStream)
  })
}

// example function that might do some async stuff (e.g. validation, logging).
// you only need bufferedstream if you have to do async stuff between when a
// request comes in and when you want to .pipe() that request somewhere
function before(req, res, callback) {
  process.nextTick(function() {
    callback()
  })
}

function createProxy(req, resp, bufferedStream) {
  // req.pipe() copies the incoming http request properties onto the new 
  // request instance
  var proxy = request()
  req.pipe(proxy)
  bufferedStream.pipe(proxy)
  proxy.pipe(resp)
  bufferedStream.resume()
}

also piping twice to the same response will result in you getting a warning that says You have already piped to this stream. Pipeing twice is likely to break the request but @mikeal is gonna fix request so that there is a method exposed that will let you clone the settings of an http request without having to use .pipe()