From 1da662687f6deaa8f39c53a3107b610dc9271279 Mon Sep 17 00:00:00 2001
From: ansuz <ansuz@transitiontech.ca>
Date: Thu, 5 Dec 2019 13:35:26 -0500
Subject: [PATCH] guarantee asynchronous execution for batch reads and write
 queues

---
 lib/batch-read.js  | 11 +++++++----
 lib/write-queue.js | 10 ++++++----
 2 files changed, 13 insertions(+), 8 deletions(-)

diff --git a/lib/batch-read.js b/lib/batch-read.js
index 3e729e66d..2852a0579 100644
--- a/lib/batch-read.js
+++ b/lib/batch-read.js
@@ -8,6 +8,8 @@ If the result of IO or computation is requested while an identical request
 is already in progress, wait until the first one completes and provide its
 result to every routine that requested it.
 
+Asynchrony is guaranteed.
+
 ## Usage
 
 Provide:
@@ -51,11 +53,12 @@ module.exports = function (/* task */) {
             var args = Array.prototype.slice.call(arguments);
 
             //if (map[id] && map[id].length > 1) { console.log("BATCH-READ DID ITS JOB for [%s][%s]", task, id); }
-
-            map[id].forEach(function (h) {
-                h.apply(null, args);
+            setTimeout(function () {
+                map[id].forEach(function (h) {
+                    h.apply(null, args);
+                });
+                delete map[id];
             });
-            delete map[id];
         });
     };
 };
diff --git a/lib/write-queue.js b/lib/write-queue.js
index c1b64ebaf..c82b12b3b 100644
--- a/lib/write-queue.js
+++ b/lib/write-queue.js
@@ -4,7 +4,7 @@ q(id, function (next) {
     // whatever you need to do....
 
     // when you're done
-    next();
+    next(); // guaranteed to be asynchronous :D
 });
 */
 
@@ -16,9 +16,11 @@ module.exports = function () {
     var map = {};
 
     var next = function (id) {
-        if (map[id] && map[id].length === 0) { return void delete map[id]; }
-        var task = map[id].shift();
-        task(fix1(next, id));
+        setTimeout(function () {
+            if (map[id] && map[id].length === 0) { return void delete map[id]; }
+            var task = map[id].shift();
+            task(fix1(next, id));
+        });
     };
 
     return function (id, task) {