couch_listener.js

var sys = require('sys');
var http = require('http');

var host = '127.0.0.1';

var couch = http.createClient(5984, host);

var listen = function() {
  sys.log("listening");
  var request = couch.request('GET', '/demo/_changes?feed=continuous', {'host': host});
  request.end();
  request.addListener('response', function (response) {
    if (response.statusCode == 200) {
      response.setEncoding('utf8');
      response.addListener('data', function (chunk) {
	sys.log(chunk);
      });
      response.addListener('end', listen);
    } else {
      setTimeout(listen, 5000);
    }
  });
};

listen();