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

Follow-up to 751fe0e1: remove dead code, group related code.

Browse Source
This commit is contained in:
David Glasser
2013-01-28 22:33:51 -08:00
parent ed0e84c4c8
commit afbebfe977
1 changed files with 22 additions and 30 deletions
Download Patch File Download Diff File Expand all files Collapse all files

52
packages/livedata/livedata_server.js
View File

@@ -854,6 +854,28 @@ _.extend(Meteor._LivedataSubscription.prototype, {
self._callStopCallbacks();
},
_callStopCallbacks: function () {
var self = this;
// tell listeners, so they can clean up
var callbacks = self._stopCallbacks;
self._stopCallbacks = [];
_.each(callbacks, function (callback) {
callback();
});
},
// Send remove messages for every document.
_removeAllDocuments: function () {
var self = this;
_.each(self._documents, function(collectionDocs, collectionName) {
// Iterate over _.keys instead of the dictionary itself, since we'll be
// mutating it.
_.each(_.keys(collectionDocs), function (strId) {
self.removed(collectionName, self._idFilter.idParse(strId));
});
});
},
// Returns a new _LivedataSubscription for the same session with the same
// initial creation parameters. This isn't a clone: it doesn't have the same
// _documents cache, stopped state or callbacks; may have a different
@@ -865,14 +887,6 @@ _.extend(Meteor._LivedataSubscription.prototype, {
self._session, self._handler, self._subscriptionId, self._params);
},
// This is meant to be used for a subscription that is about to be rerun.
// It does NOT invoke the remove() callbacks on the session for every doc.
_resetSubscription: function () {
var self = this;
self._callStopCallbacks();
self._documents = {};
},
onStop: function (callback) {
var self = this;
if (self._stopped)
@@ -919,29 +933,7 @@ _.extend(Meteor._LivedataSubscription.prototype, {
self._session.sendComplete([self._subscriptionId]);
self._complete = true;
}
},
_callStopCallbacks: function () {
var self = this;
// tell listeners, so they can clean up
var callbacks = self._stopCallbacks;
self._stopCallbacks = [];
_.each(callbacks, function (callback) {
callback();
});
},
// Send remove messages for every document.
_removeAllDocuments: function () {
var self = this;
_.each(self._documents, function(collectionDocs, collectionName) {
// Iterate over _.keys instead of the dictionary itself, since we'll be
// mutating it.
_.each(_.keys(collectionDocs), function (strId) {
self.removed(collectionName, self._idFilter.idParse(strId));
});
});
}
});
/******************************************************************************/