summaryrefslogtreecommitdiff
path: root/node_modules/webpack/lib/util/processAsyncTree.js
diff options
context:
space:
mode:
authorlittleblack111 <littleblack11111@gmail.com>2023-10-31 15:37:35 +0800
committerlittleblack111 <littleblack11111@gmail.com>2023-10-31 15:37:35 +0800
commitd5f14083061f2ce6a42313188443a42e30796320 (patch)
treecc6a9889e08b29595a76a33b9e7b4ef84866468b /node_modules/webpack/lib/util/processAsyncTree.js
parentb1a6ea021f29f182b62f9f81024a3d8ac8621b7f (diff)
added make browserlist(autoprefixer) work fixed
Diffstat (limited to 'node_modules/webpack/lib/util/processAsyncTree.js')
-rw-r--r--node_modules/webpack/lib/util/processAsyncTree.js68
1 files changed, 68 insertions, 0 deletions
diff --git a/node_modules/webpack/lib/util/processAsyncTree.js b/node_modules/webpack/lib/util/processAsyncTree.js
new file mode 100644
index 00000000..38253865
--- /dev/null
+++ b/node_modules/webpack/lib/util/processAsyncTree.js
@@ -0,0 +1,68 @@
+/*
+ MIT License http://www.opensource.org/licenses/mit-license.php
+ Author Tobias Koppers @sokra
+*/
+
+"use strict";
+
+/**
+ * @template T
+ * @template {Error} E
+ * @param {Iterable<T>} items initial items
+ * @param {number} concurrency number of items running in parallel
+ * @param {function(T, function(T): void, function(E=): void): void} processor worker which pushes more items
+ * @param {function(E=): void} callback all items processed
+ * @returns {void}
+ */
+const processAsyncTree = (items, concurrency, processor, callback) => {
+ const queue = Array.from(items);
+ if (queue.length === 0) return callback();
+ let processing = 0;
+ let finished = false;
+ let processScheduled = true;
+
+ /**
+ * @param {T} item item
+ */
+ const push = item => {
+ queue.push(item);
+ if (!processScheduled && processing < concurrency) {
+ processScheduled = true;
+ process.nextTick(processQueue);
+ }
+ };
+
+ /**
+ * @param {E | null | undefined} err error
+ */
+ const processorCallback = err => {
+ processing--;
+ if (err && !finished) {
+ finished = true;
+ callback(err);
+ return;
+ }
+ if (!processScheduled) {
+ processScheduled = true;
+ process.nextTick(processQueue);
+ }
+ };
+
+ const processQueue = () => {
+ if (finished) return;
+ while (processing < concurrency && queue.length > 0) {
+ processing++;
+ const item = /** @type {T} */ (queue.pop());
+ processor(item, push, processorCallback);
+ }
+ processScheduled = false;
+ if (queue.length === 0 && processing === 0 && !finished) {
+ finished = true;
+ callback();
+ }
+ };
+
+ processQueue();
+};
+
+module.exports = processAsyncTree;