aboutsummaryrefslogtreecommitdiff
path: root/tools/schedule.js
diff options
context:
space:
mode:
Diffstat (limited to 'tools/schedule.js')
-rw-r--r--tools/schedule.js10
1 files changed, 10 insertions, 0 deletions
diff --git a/tools/schedule.js b/tools/schedule.js
index e2af9db..42ec127 100644
--- a/tools/schedule.js
+++ b/tools/schedule.js
@@ -24,6 +24,7 @@ exports.Queue = function(delayms, maxExport, call){
let prios = []; // Array of priorities (keys of jobs), sorted.
let open = true; // Is dequeue() allowed to be called (i.e., has the timeout expired?)
let disab = true; // Is the queue disabled?
+ let pauseCall = null; // Either null or a function which will replace the next dequeue() call.
this.enqueue = function(job){
if (! job[0]) return;
@@ -46,6 +47,10 @@ exports.Queue = function(delayms, maxExport, call){
this.disable = function(){
disab = true;
}
+
+ this.pause = function(call){ // run `call()` instead of `dequeue()` when timeout expires. Just do it once (overwrites other calls)
+ pauseCall = call;
+ }
function dequeue(){
// Wraps getNumOrAll, managing open/disab, and concatenating possibly multiple layers
@@ -57,6 +62,11 @@ exports.Queue = function(delayms, maxExport, call){
open = true;
return;
}
+ if (pauseCall){
+ call();
+ pauseCall = null;
+ return;
+ }
open = false;
let data = [];
while (prios.length > 0 && data.length < maxExport){