stream based dat replication

client.js

var replication = require(...)

var r = replication(datInstance)
var socket = net.connect(9090, 'localhost')

socket.pipe(r.createPushStream()).pipe(socket)

server.js

var replication = require(...)

var r = replication(datInstance)

net.createServer(function(socket) {
  socket.pipe(r.createPullStream()).pipe(socket)
}).listen(9090)