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

use docfetcher

Browse Source
This commit is contained in:
David Glasser
2013-09-18 13:58:13 -07:00
parent 33528ddbc3
commit 0017eacbe9
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -124,6 +124,7 @@ MongoConnection = function (url, connectionOptions) {
}).run();
});
self._docFetcher = new DocFetcher(self);
self._oplogHandle = null;
// XXX we should NOT be reading directly from the env here (this should be an
// argument to MongoConnection eg) but I want to wait for the AppConfig API to
@@ -375,10 +376,10 @@ MongoConnection.prototype._observeChangesWithOplog = function (
if (isModifier) {
// XXX problem is, the result of this findOne is delivered at a random
// time, not necessarily synced with other stuff that may be coming down
// the oplog. also, we should coalesce multiple pings of the same
// document ("ID queue"). also, we shouldn't read fields that aren't
// the oplog. also, we shouldn't read fields that aren't
// necessary to evaluate selector or to publish.
newDoc = self.findOne(cursorDescription.collectionName, {_id: id});
newDoc = self._docFetcher.fetch(cursorDescription.collectionName, id,
op.ts.toString());
} else {
newDoc = _.extend({_id: id}, op.o);
}