[kames]

// server
 var es = require('event-stream');
require('net').createServer(function (socket) {
    console.log('CONNECTED: ' + socket.remoteAddress +':'+ socket.remotePort);
    socket.pipe(es.split())
    .pipe(es.map(function (data, cb) {
        console.log('Got the following message:', data);
        cb(null)
    }));
    socket.on('end', function () {
        console.log("ended: ", socket.remoteAddress, " : ", socket.remotePort);
    });

})
.listen(3000);

Была у меня ещё такая реализация но там почему-то добавляется пустой квадрат перед e[{}]