x.js

mdm.on("connection", function (stream) {
    var bufferWritable = through()
        , bufferReadable = PauseStream().pause()
        , buffer = duplex(bufferWritable, bufferReadable)

    // effectively call stream.pause() and make sure its buffered until
    // I can deal with that data
    bufferWritable.pipe(stream).pipe(bufferReadable)  
})