var Telephone = require('telephone_duplexer'),
net = require('net');
var server = net.createServer(function(socket) {
var tele = new Telephone(socket);
tele.on('client', function(msg, reply) {
console.log('SERVER: ' + msg);
reply("Tyler Durden");
});
setInterval(function() {
tele.emit('server', 'I AM YOUR SERVER LUKE!');
}, 3000);
});
server.listen(5001);
var client = net.createConnection({host: 'localhost', port: 5001}, function() {
var tele = new Telephone(client);
tele.on('server', function(msg) {
console.log('CLIENT: ' + msg);
});
setInterval(function() {
tele.emit('client', 'USE THE FORCE', function(name) {
console.log("CALLBACK: my name is " + name);
});
}, 3000);
});