github/meteor
1
1
Fork 0
mirror of https://github.com/meteor/meteor.git synced 2026-05-02 03:01:46 -04:00
Code Issues Packages Projects Releases Wiki Activity

Until I do the right thing, it's slightly more right to do the query before

Browse Source 
listening.
This commit is contained in:
David Glasser
2013-09-12 21:17:26 -07:00
parent a93f742b3a
commit 5a4ae936aa
1 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
packages/mongo-livedata/mongo_driver.js
View File

@@ -337,6 +337,12 @@ MongoConnection.prototype._observeChangesWithOplog = function (
callbacks.removed && callbacks.removed(id);
};
// XXX the ordering here is wrong
var initialCursor = new Cursor(self, cursorDescription);
initialCursor.forEach(function (initialDoc) {
add(initialDoc);
});
var oplogHandle = self._oplogHandle.onOplogEntry(cursorDescription.collectionName, function (op) {
var id;
if (op.op === 'd') {
@@ -353,8 +359,9 @@ MongoConnection.prototype._observeChangesWithOplog = function (
// XXX what if selector yields? for now it can't but later it could have
// $where
if (selector(op.o))
if (selector(op.o)) {
add(op.o);
}
} else if (op.op === 'u') {
id = op.o2._id;
@@ -423,11 +430,6 @@ MongoConnection.prototype._observeChangesWithOplog = function (
}
);
var initialCursor = new Cursor(self, cursorDescription);
initialCursor.forEach(function (initialDoc) {
add(initialDoc);
});
var observeHandle = {
stop: function () {
oplogHandle.stop();