diff --git a/packages/mongo-livedata/oplog.js b/packages/mongo-livedata/oplog.js index 163e01590b..566bff264d 100644 --- a/packages/mongo-livedata/oplog.js +++ b/packages/mongo-livedata/oplog.js @@ -196,12 +196,9 @@ MongoConnection.prototype._observeChangesWithOplog = function ( var oplogEntryHandle = self._oplogHandle.onOplogEntry( cursorDescription.collectionName, function (op) { if (op.op === 'c') { - // If it is not db.collection.drop(), ignore it - if (op.o && _.isEqual(_.keys(op.o), ['drop'])) { - published.each(function (fields, id) { - remove(id); - }); - } + published.each(function (fields, id) { + remove(id); + }); } else { // All other operators should be handled depending on phase oplogEntryHandlers[phase](op);