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

Rework reactive logic for new Sky.deps API.

Browse Source
This commit is contained in:
Nick Martin
2011-12-19 16:53:14 -08:00
parent 8503c55453
commit d38efe6345
1 changed files with 9 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
packages/stream/stream_client.js
View File

@@ -50,13 +50,11 @@ if (typeof Sky === "undefined") Sky = {};
var status = {
status: "startup", connected: false, retry_count: 0
};
var status_listeners = [];
var status_listeners = {}; // context.id -> context
var status_changed = function () {
// XXX does _.each do the right thing if the list is modified out
// from under it? The list will be modified out from under it until
// Geoff's flush changes land (and even then, may still be modified
// out from under us?).
_.each(status_listeners, function (x) { x(); });
_.each(status_listeners, function (context) {
context.invalidate();
});
};
//// retry logic
@@ -175,11 +173,11 @@ if (typeof Sky === "undefined") Sky = {};
////////// User facing API //////////
Sky.status = function () {
if (Sky.deps.monitoring) {
var invalidate = Sky.deps.getInvalidate();
status_listeners.push(invalidate);
Sky.deps.cleanup(function () {
status_listeners = _.without(status_listeners, invalidate);
var context = Sky.deps.Context.current;
if (context && !(context.id in status_listeners)) {
status_listeners[context.id] = context;
context.on_invalidate(function () {
delete status_listeners[context.id];
});
}
return status;