From 16da8f48c7328c334a5c0d863078fd00257ae6b4 Mon Sep 17 00:00:00 2001
From: Minteck <contact@minteck.org>
Date: Sun, 8 May 2022 13:18:04 +0200
Subject: Initial commit

---
 fetcher/node_modules/asynckit/parallel.js | 43 +++++++++++++++++++++++++++++++
 1 file changed, 43 insertions(+)
 create mode 100644 fetcher/node_modules/asynckit/parallel.js

(limited to 'fetcher/node_modules/asynckit/parallel.js')

diff --git a/fetcher/node_modules/asynckit/parallel.js b/fetcher/node_modules/asynckit/parallel.js
new file mode 100644
index 0000000..3c50344
--- /dev/null
+++ b/fetcher/node_modules/asynckit/parallel.js
@@ -0,0 +1,43 @@
+var iterate    = require('./lib/iterate.js')
+  , initState  = require('./lib/state.js')
+  , terminator = require('./lib/terminator.js')
+  ;
+
+// Public API
+module.exports = parallel;
+
+/**
+ * Runs iterator over provided array elements in parallel
+ *
+ * @param   {array|object} list - array or object (named list) to iterate over
+ * @param   {function} iterator - iterator to run
+ * @param   {function} callback - invoked when all elements processed
+ * @returns {function} - jobs terminator
+ */
+function parallel(list, iterator, callback)
+{
+  var state = initState(list);
+
+  while (state.index < (state['keyedList'] || list).length)
+  {
+    iterate(list, iterator, state, function(error, result)
+    {
+      if (error)
+      {
+        callback(error, result);
+        return;
+      }
+
+      // looks like it's the last one
+      if (Object.keys(state.jobs).length === 0)
+      {
+        callback(null, state.results);
+        return;
+      }
+    });
+
+    state.index++;
+  }
+
+  return terminator.bind(state, callback);
+}
-- 
cgit