|
|
@ -68,7 +68,6 @@ var isEmpty = function (map) {
|
|
|
|
return true;
|
|
|
|
return true;
|
|
|
|
};
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
|
|
// XXX enforce asynchrony everywhere
|
|
|
|
|
|
|
|
module.exports = function () {
|
|
|
|
module.exports = function () {
|
|
|
|
// every scheduler instance has its own queue
|
|
|
|
// every scheduler instance has its own queue
|
|
|
|
var queue = WriteQueue();
|
|
|
|
var queue = WriteQueue();
|
|
|
@ -111,7 +110,7 @@ module.exports = function () {
|
|
|
|
if (typeof(local.waiting) !== 'function') {
|
|
|
|
if (typeof(local.waiting) !== 'function') {
|
|
|
|
return void collectGarbage();
|
|
|
|
return void collectGarbage();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
local.waiting();
|
|
|
|
setTimeout(local.waiting);
|
|
|
|
});
|
|
|
|
});
|
|
|
|
};
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
|
|