From 4bd0a90631cc07d1433a11079bfc2d54d51fb644 Mon Sep 17 00:00:00 2001
From: Holden Rohrer <holden.rohrer@gmail.com>
Date: Tue, 24 Dec 2019 20:55:52 -0500
Subject: added queue.js to simplify jarvis

---
 examples/jarvis.js | 16 +++-------------
 1 file changed, 3 insertions(+), 13 deletions(-)

(limited to 'examples/jarvis.js')

diff --git a/examples/jarvis.js b/examples/jarvis.js
index d60bc44..00b4610 100644
--- a/examples/jarvis.js
+++ b/examples/jarvis.js
@@ -5,6 +5,7 @@ const Socket = require('../socket');
 const getdims = require('../utils/getdims');
 const tilekeys = require('../utils/tilekeys');
 const Search = require('../tools/search');
+const Queue = require('../tools/queue');
 
 var main = new Socket();
 
@@ -57,21 +58,10 @@ function identity(sender){
 let response = new Space();
 response.adhoc('yes, my liege');
 
-let queue = []; // Must be expanded to handle actual use cases
-let open = true;
-function dequeue(){
-  if (queue.length == 0)
-    open = true;
-  else{
-    open = false;
-    main.write(queue.shift()) // Make more general (possibly a function pointer or a conf variable)
-    setTimeout(dequeue, 1000);
-  }
-}
+let writes = new Queue(1000, 200, (elems) => main.write(elems));
 
 function respond(coord){
   console.log('called at', coord);
   response.loc = coord;
-  queue.push(response.towrite());
-  if (open) dequeue();
+  writes.enqueue(...response.towrite());
 }
-- 
cgit