listener.js

var airport = require('airport');
var fs = require('fs');
var net = require('net');

var air = airport('localhost', 9090);
var listener = air.connect('watcher');

var server = net.createServer(function(socket) {
  listener(function(remote) {
    console.log(remote);

    socket.on('data', function(d) {
      console.log(d);
    });

    this.socket = function(cb) {
      cb(socket);
    }
  });
});

watcher.js

var watch = require('watch');
var airport = require('airport');
var air = airport('localhost', 9090);
var fs = require('fs');

air(function(remote, connection) {

  console.log(remote, connection);

  watch.createMonitor('./dir1', function(monitor) {
    monitor.on('created', function(f, stat) {

      remote.socket(function(s) {
        fs.createReadStream(f).pipe(s);
      });

    });

    monitor.on('changed', function(f, curr, prev) {
      console.log('changed', f, curr, prev);
    });

    monitor.on('removed', function(f, stat) {
      console.log('removed', f, stat);
    });

  });

  this.foo = function() {

  }

}).listen('watcher');