EventEmitter on _all_dbs
var allDBsChangesPool = require('all-dbs-changes');
var couch_url = 'http://localhost:5984';
allDBsChangesPool.start(couch_url, function (err, pool) {
if (err) {
console.log(err);
}
pool.on('change', function (db) {
db.data.results.forEach(function (result) {
/.../
});
});
});
- request queue
- pass through options to changes feed.