app.js

var MuxDemux = require('mux-demux');
var net = require('net');
var es = require('event-stream');
var ms = require('msgpack-stream');

net.createServer(function (con) {
    var mdm = MuxDemux({wrapper: function (stream) {
        return es.pipeline(ms.createDecodeStream(), stream, ms.createEncodeStream())
    }}, function (stream) {
        console.log("Connection: ", stream);
        stream.on('data', function (data) {
            console.log(data);
        });
    });
    mdm.pipe(con).pipe(mdm);

    con.clientid = mdm.createID();
    console.log(con);
    con.pipe(mdm).pipe(con);
}).listen(8642);