Create a gist now

Instantly share code, notes, and snippets.

What would you like to do?
Code that manages queues for River5, for review. See the blog post linked to in the first comment.
function readRiverFile (relpath, callback) {
var f = config.dataFolder + relpath;
if (riverQueues [f] === undefined) {
riverQueues [f] = [callback];
fs.readFile (f, function (err, data) {
if (err) {
console.log ("readRiverFile: err.message == " + err.message);
}
else {
var theQueue = riverQueues [f];
delete riverQueues [f];
for (var i = 0; i < theQueue.length; i++) {
theQueue [i] (data);
}
}
});
}
else {
riverQueues [f].push (callback);
}
}
Owner

scripting commented Jan 13, 2018

Here's the blog post with the background --

http://scripting.com/2018/01/13/183433.html

Dave

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment