var net = require('net');
var actorify = require('actorify');
var reconnect = require('reconnect');
var distribute = require('stream-distribute-thing');
// server
net.createServer(onconnect).listen(3000);
net.createServer(onconnect).listen(3001);
function onconnect (sock){
 var actor = actorify(sock);
 actor.on('ping', function(){
 console.log('PING');
 actor.send('pong');
 });
}
// client
var services = distribute([
 reconnect(3000),
 reconnect(3001)
]);
var actor = actorify(services);
setInterval(function(){
 actor.send('ping');
 actor.once('pong', function(){
 console.log('PONG');
 });
}, 300);