var OplogObservable = require('mongo-oplog-observable'); var oplog = OplogObservable({ uri: 'mongodb://127.0.0.1:12345/local', ns: 'myDatabase.myCollection' }); var inserts = oplog.filter(function(e){ return e.op === 'i'; }); var updates = oplog.filter(function(e){ return e.op === 'u'; }); var deletes = oplog.filter(function(e){ return e.op === 'd'; }); oplog.subscribe( function onNext(event){ console.log('Next'); console.log(event); }, function onError(err){ console.log('Error'); console.log(err); }, function onCompleted() { console.log('Completed'); } );