new pipe-able dnode api

connect.js

var dnode = require('../../lib/dnode');
var net = require('net');

var d = new dnode();
d.on('remote', function (remote) {
    remote.transform('beep', function (s) {
        console.log('beep => ' + s);
        d.end();
    });
});

var c = net.connect(5004);
c.pipe(d).pipe(c);

listen.js

var dnode = require('../../lib/dnode');
var net = require('net');

var server = net.createServer(function (c) {
    var d = new dnode({
        transform : function (s, cb) {
            cb(s.replace(/[aeiou]{2,}/, 'oo').toUpperCase())
        }
    });
    c.pipe(d).pipe(c);
});

server.listen(5004);

output

substack : stream $ node listen.js &
[1] 19229
substack : stream $ node connect.js 
beep => BOOP
substack : stream $