//server 
var RPC = require('rpc-with-streams')
var net = require('net')
var fs = require('fs')
 
var rpc = RPC(fs)
net.createStream(function (stream) {
  stream.pipe(rpc).pipe(stream)
}).listen(PORT)

//client 
var RPC = require('rpc-with-streams')
var net = require('net')
var rpc = RPC(fs)
var stream = net.connect(PORT)
 
stream.pipe(rpc).pipe(stream)
//create a partial wrapper of the fs module. 
var fs = rpc.wrap(
  ['readFile', 'writeFile', 'unlinkFile', 'stat'],
  ['createReadStream', 'createWriteStream']
)