Duplex stream chat through TCP

client.js

var net = require('net');
var port = 8001;

var socket = new net.Socket();
socket.connect(port, function () {
  console.log("Connected to", port);
});

process.stdin.pipe(socket).pipe(process.stdout);

server.js

var net = require('net');
var through = require('through2');
var port = 8001;

net.createServer(function (connection) {
  process.stdin
    .pipe(connection)
    .pipe(through(prefix))
    .pipe(connection)
    .pipe(process.stdout);

  process.stdin.pipe(through(prefix)).pipe(process.stdout);
}).listen(port, function () {
  console.log('Listening on port', port);
});

function prefix (data, enc, cb) {
  this.push(new Buffer('You said: ' + data.toString()));
  cb();
}