// Server.js
"use strict";
var PExchange = require("pexchange");
var Server = new PExchange.Server('/tmp/pexchange.sock');
 
Server.on('Ping', function(Request, Job){
  Job.Result = 'Pong';
  Server.Finished(Job);
});

// Client.js
var PExchange = require("pexchange");
var Client = new PExchange.Client('/tmp/pexchange.sock');
 
Client.connect(function(){
  Client.Request("Ping").then(function(Response){
    console.log(Response); // "Pong"
  });
});

enum JobType:string{
  Request, Reply, Broadcast
}
type ServerJob = shape( Type:JobType, SubType:String, Message:String, ID:String, Socket:Net.Socket )
type ClientJob = shape( Type:JobType, SubType:String, Message:String, ID:String )
class ExchangeServer extends EventEmitter{
  Server: Net.Server
  Connections: array<Net.Socket>
  on(Type:String, Callback:function(Job:ServerJob))
  Broadcast(Type:String, Message:String, ?Socket:Net.Socket):this
  Request(Type:String, Message:String, ?Socket:Net.Socket):Promise<String>
  Finished(Job)
}
class ExchangeClient extends EventEmitter{
  on(Type:String, Callback:function(Job:ClientJob))
  Broadcast(Type:String, Message:String, ?Socket:Net.Socket):this
  Request(Type:String, Message:String, ?Socket:Net.Socket):Promise<String>
  Finished(Job)  
}