pausing a stream in shoejs

invert.js

var http = require('http');
var ecstatic = require('ecstatic')(__dirname + '/static');
var shoe = require('../../');
var through = require('through') 
var net = require('net')
 
// Goal:
// pipe connection on port 10000 to port 9999
// but do some async operation
// before doing so
net.createServer(function(socket) {
  var pause = through().pause()
  socket.pipe(pause)
  setTimeout(function() {
    pause.pipe(net.connect(9999)).pipe(socket)
    pause.resume()
  }, 1000)
}).listen(10000)
 
var server = http.createServer(ecstatic);
server.listen(9999);
 
var sock = shoe(function (stream) {
    var iv = setInterval(function () {
        stream.write(Math.floor(Math.random() * 2));
    }, 250);
    
    stream.on('end', function () {
        clearInterval(iv);
    });
    
    stream.pipe(process.stdout, { end : false });
});
sock.install(server, '/invert');