muxdemux

function multiStream(){
  var mdm = MuxDemux();
  mdm.once('connection', connectNew);
  mdm.on('connection', connectHandler);
  mdm.on('error', function(err){
    console.log(err.toString());
    mdm.destroy();
  });

  mdm.send = function(msg){
    this.createWriteStream('msg').write(msg);
  };

  mdm.broadcast = function(msg){
    for (var key in socks) {
      if (this.peerId != key) {
        socks[key].createWriteStream('msg').write(msg);
      }
    }
    console.log('BROADCAST: ' + msg);
  };

  return mdm;
}