commit 8f06b9d504c298fada9123147b38531c89e3727f
Author: Sven Slootweg <admin@cryto.net>
Date:   Sat Mar 27 19:12:35 2021 +0100

    Initial commit

diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..3c3629e
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1 @@
+node_modules
diff --git a/example-ordered.js b/example-ordered.js
new file mode 100644
index 0000000..8807f62
--- /dev/null
+++ b/example-ordered.js
@@ -0,0 +1,23 @@
+"use strict";
+
+const Promise = require("bluebird");
+const pipe = require("@promistream/pipe");
+const collect = require("@promistream/collect");
+const rangeNumbers = require("@promistream/range-numbers");
+const map = require("@promistream/map");
+const parallelize = require("./");
+
+return Promise.try(() => {
+	return pipe([
+		rangeNumbers(0, 20),
+		map((value) => {
+			let delay = Math.floor(Math.random() * 100);
+
+			return Promise.delay(delay).then(() => value);
+		}),
+		parallelize(3),
+		collect()
+	]).read();
+}).then((results) => {
+	console.log(results);
+});
diff --git a/example-unordered.js b/example-unordered.js
new file mode 100644
index 0000000..fad8fc3
--- /dev/null
+++ b/example-unordered.js
@@ -0,0 +1,23 @@
+"use strict";
+
+const Promise = require("bluebird");
+const pipe = require("@promistream/pipe");
+const collect = require("@promistream/collect");
+const rangeNumbers = require("@promistream/range-numbers");
+const map = require("@promistream/map");
+const parallelize = require("./");
+
+return Promise.try(() => {
+	return pipe([
+		rangeNumbers(0, 20),
+		map((value) => {
+			let delay = Math.floor(Math.random() * 100);
+
+			return Promise.delay(delay).then(() => value);
+		}),
+		parallelize(3, { ordered: false }),
+		collect()
+	]).read();
+}).then((results) => {
+	console.log(results);
+});
diff --git a/index.js b/index.js
new file mode 100644
index 0000000..c517baa
--- /dev/null
+++ b/index.js
@@ -0,0 +1,232 @@
+"use strict";
+
+const Promise = require("bluebird");
+const isEndOfStream = require("@promistream/is-end-of-stream");
+const isAborted = require("@promistream/is-aborted");
+const propagateAbort = require("@promistream/propagate-abort");
+const pipe = require("@promistream/pipe");
+const sequentialize = require("@promistream/sequentialize");
+const defaultValue = require("default-value");
+const debug = require("debug")("promistream:parallelize");
+
+const createPromiseListener = require("./promise-listener");
+
+// FIXME: Verify that if an EndOfStream or Aborted marker comes in, it is left queued up until all of the in-flight non-marker results have been processed; otherwise the downstream may erroneously believe that the stream has already ended, while more items are still on their way
+
+module.exports = function parallelizeStream(threadCount, options = {}) {
+	let ordered = defaultValue(options.ordered, true);
+
+	/* TODO: Does this need a more efficient FIFO queue implementation? */
+	let signals = [];
+	let storedErrors = [];
+	let queueListener = createPromiseListener();
+	let parallelMode = true;
+	let filling = false;
+	let currentSource = null;
+
+	function fillRequest() {
+		if (parallelMode === true && signals.length < threadCount) {
+			return Promise.try(() => {
+				return currentSource.peek();
+			}).then((valueAvailable) => {
+				if (valueAvailable) {
+					queueRead();
+					
+					return fillRequest(currentSource);
+				} else {
+					return switchToSequentialMode();
+				}
+			});
+		} else {
+			debug(`Paused internal queue fill (parallel mode = ${parallelMode}, thread count = ${threadCount}, in-flight requests = ${signals.length})`);
+			filling = false;
+		}
+	}
+
+	function tryStartFilling() {
+		if (!filling) {
+			debug("Starting internal queue fill...");
+			filling = true;
+
+			return fillRequest(currentSource);
+		}
+	}
+
+	function switchToParallelMode() {
+		debug("Switching to parallel mode");
+		parallelMode = true;
+
+		return tryStartFilling();
+	}
+
+	function switchToSequentialMode() {
+		debug("Switching to sequential mode");
+		parallelMode = false;
+	}
+
+	function bufferNotEmpty() {
+		/* NOTE: This should *only* take into account items that have not been peeked yet! */
+		let peekedSignal;
+
+		if (ordered) {
+			/* This will return only if there is a contiguous sequence of settled signals from the start, of which *at least one* has not been peeked yet. */
+			for (let signal of signals) {
+				if (signal.trackingPromise.isPending()) {
+					break;
+				} else if (signal.peeked) {
+					continue;
+				} else {
+					/* Settled, and not peeked yet. */
+					peekedSignal = signal;
+					break;
+				}
+			}
+		} else {
+			peekedSignal = signals.find((signal) => {
+				return !(signal.trackingPromise.isPending()) && !signal.peeked;
+			});
+		}
+
+		if (peekedSignal != null) {
+			peekedSignal.peeked = true;
+			return true;
+		} else {
+			return false;
+		}
+	}
+
+	function awaitInFlightRequests() {
+		if (signals.length > 0) {
+			return true;
+		} else {
+			debug("Waiting for queue to be non-empty...");
+
+			return Promise.try(() => {
+				return queueListener.listen();
+			}).tap(() => {
+				debug("Got queue-filled notification");
+			}).tapCatch((error) => {
+				debug(`Queue listener rejected: ${error.stack}`);
+			});
+		}
+	}
+
+	function queueRead() {
+		let promise = Promise.try(() => {
+			return currentSource.read();
+		});
+
+		let signalObject = { promise: promise };
+
+		signals.push({
+			peeked: false,
+			object: signalObject,
+			trackingPromise: Promise.try(() => {
+				return promise.reflect();
+			}).then(() => {
+				return signalObject;
+			})
+		});
+
+		queueListener.resolve();
+	}
+
+	function awaitResult() {
+		return Promise.try(() => {
+			return awaitInFlightRequests();
+		}).then(() => {
+			debug("Awaiting next finished result...");
+			if (ordered) {
+				return signals[0].trackingPromise;
+			} else {
+				return Promise.race(signals.map((item) => item.trackingPromise));
+			}
+		}).then((signalObject) => {
+			let resultPromise = signalObject.promise;
+			
+			signals = signals.filter((signal) => (signal.object !== signalObject));
+
+			let isRejected = resultPromise.isRejected();
+			let isEndOfStream_ = isRejected && isEndOfStream(resultPromise.reason());
+			let isAborted_ = isRejected && isAborted(resultPromise.reason());
+
+			if (isEndOfStream_ || isAborted_) {
+				switchToSequentialMode();
+
+				if (signals.length > 0) {
+					/* Throw away the marker, and wait for the next result */
+					return awaitResult();
+				} else {
+					/* Queue has been exhausted, so this marker will be the final result; pass it through */
+					return signalObject.promise;
+				}
+			} else {
+				return signalObject.promise;
+			}
+		});
+	}
+
+	let parallelizer = {
+		_promistreamVersion: 0,
+		description: `parallelize (${threadCount} threads)`,
+		abort: propagateAbort,
+		peek: function (source) {
+			return Promise.try(() => {
+				debug("Processing peek...");
+
+				if (bufferNotEmpty()) {
+					return true;
+				} else {
+					if (parallelMode === true) {
+						return source.peek();
+					} else {
+						return false;
+					}
+				}
+			});
+		},
+		read: function (source) {
+			return Promise.try(() => {
+				debug("Processing read...");
+				currentSource = source;
+
+				if (storedErrors.length > 0) {
+					throw storedErrors.shift();
+				} else {
+					if (parallelMode) {
+						/* This runs in the background, potentially perpetually */
+						Promise.try(() => {
+							return tryStartFilling();
+						}).catch((err) => {
+							queueListener.reject(err);
+							debug(`Error occurred during filling: ${err.stack}`);
+							// storedErrors.push(err);
+						});
+
+						return awaitResult();
+					} else {
+						/* Sequential mode */
+						if (signals.length > 0) {
+							/* Clear out the remaining in-flight reads from the previous parallel-mode operation, first. */
+							return awaitResult();
+						} else {
+							debug("Passing through read to upstream...");
+
+							return Promise.try(() => {
+								return source.read();
+							}).then((result) => {
+								switchToParallelMode();
+								return result;
+							});
+						}
+					}
+				}
+			});
+		}
+	};
+
+	return pipe([
+		parallelizer,
+		sequentialize()
+	]);
+};
diff --git a/package.json b/package.json
new file mode 100644
index 0000000..83c126a
--- /dev/null
+++ b/package.json
@@ -0,0 +1,18 @@
+{
+  "name": "@promistream/parallelize",
+  "version": "0.1.0",
+  "main": "index.js",
+  "repository": "http://git.cryto.net/promistream/parallelize.git",
+  "author": "Sven Slootweg <admin@cryto.net>",
+  "license": "WTFPL OR CC0-1.0",
+  "dependencies": {
+    "@promistream/is-aborted": "^0.1.1",
+    "@promistream/is-end-of-stream": "^0.1.1",
+    "@promistream/pipe": "^0.1.4",
+    "@promistream/propagate-abort": "^0.1.2",
+    "@promistream/sequentialize": "^0.1.0",
+    "bluebird": "^3.5.4",
+    "debug": "^4.1.1",
+    "default-value": "^1.0.0"
+  }
+}
diff --git a/promise-listener.js b/promise-listener.js
new file mode 100644
index 0000000..5918d9d
--- /dev/null
+++ b/promise-listener.js
@@ -0,0 +1,30 @@
+"use strict";
+
+module.exports = function createPromiseListener() {
+	let listeners = [];
+
+	function consumeListeners() {
+		/* To ensure that a resolve/reject is atomic, and can never apply to the same listener queue twice. */
+		let consumedListeners = listeners;
+		listeners = [];
+		return consumedListeners;
+	}
+
+	return {
+		listen: function () {
+			return new Promise((resolve, reject) => {
+				listeners.push({ resolve, reject });
+			});
+		},
+		resolve: function (value) {
+			consumeListeners().forEach((listener) => {
+				listener.resolve(value);
+			});
+		},
+		reject: function (value) {
+			consumeListeners().forEach((listener) => {
+				listener.reject(value);
+			});
+		},
+	}
+};
\ No newline at end of file
diff --git a/yarn.lock b/yarn.lock
new file mode 100644
index 0000000..4a1728f
--- /dev/null
+++ b/yarn.lock
@@ -0,0 +1,384 @@
+# THIS IS AN AUTOGENERATED FILE. DO NOT EDIT THIS FILE DIRECTLY.
+# yarn lockfile v1
+
+
+"@joepie91/unreachable@^1.0.0":
+  version "1.0.0"
+  resolved "https://registry.yarnpkg.com/@joepie91/unreachable/-/unreachable-1.0.0.tgz#8032bb8a5813e81bbbe516cb3031d60818526687"
+  integrity sha512-vZRJ5UDq4mqP1vgSrcOLD3aIfS/nzwsvGFOOHv5sj5fa1Ss0dT1xnIzrXKLD9pu5EcUvF3K6n6jdaMW8uXpNEQ==
+
+"@promistream/is-aborted@^0.1.1":
+  version "0.1.1"
+  resolved "https://registry.yarnpkg.com/@promistream/is-aborted/-/is-aborted-0.1.1.tgz#58d714dbd5f20bf851c77339c2213128ac50f0bf"
+  integrity sha512-2AYo+MFu0wNKXCEDHexaFWoESiUzHfGZgWpazbdA6OyU/AJsHRfMwKzE7awmgi1u0T43k5nLwwJXIiTypajSiw==
+
+"@promistream/is-end-of-stream@^0.1.1":
+  version "0.1.1"
+  resolved "https://registry.yarnpkg.com/@promistream/is-end-of-stream/-/is-end-of-stream-0.1.1.tgz#7f84e630c9e49a92739df6a8c574eff99dd4c09d"
+  integrity sha512-GZn7W0wrUen7kkgWCcwFFgr0g/ftfuddnuK/Tp0MLWCCJA4hyAboglCZP0JzEJdi34gClEP8lCfDwGekw18LHg==
+
+"@promistream/pipe@^0.1.4":
+  version "0.1.4"
+  resolved "https://registry.yarnpkg.com/@promistream/pipe/-/pipe-0.1.4.tgz#ef05fe582a33768c7eb56ad20635e1b7b48ac95b"
+  integrity sha512-4js6lhu/aTNEMosIBFcCz8Rkxc1S2V4zzI2QvZp9HqglhL5UTuxnv5VbU2ZlPFAFVID1aJOurZ8KdiVagHfOCw==
+  dependencies:
+    "@validatem/allow-extra-properties" "^0.1.0"
+    "@validatem/anything" "^0.1.0"
+    "@validatem/array-of" "^0.1.2"
+    "@validatem/core" "^0.3.15"
+    "@validatem/error" "^1.1.0"
+    "@validatem/remove-nullish-items" "^0.1.0"
+    "@validatem/required" "^0.1.1"
+    "@validatem/wrap-error" "^0.3.0"
+
+"@promistream/propagate-abort@^0.1.2":
+  version "0.1.6"
+  resolved "https://registry.yarnpkg.com/@promistream/propagate-abort/-/propagate-abort-0.1.6.tgz#dfc3c78c2e22662b9e5d548afce2180c40584ef5"
+  integrity sha512-Ap4eDFiIcLb4yuJdin2tQM1+2ZJZm78sYWkKVdqECJY0UGkwNsbaMMeYyfZpFRpJGmW8mCCuOkWs0fQl5H9DGA==
+
+"@promistream/sequentialize@^0.1.0":
+  version "0.1.0"
+  resolved "https://registry.yarnpkg.com/@promistream/sequentialize/-/sequentialize-0.1.0.tgz#8cab499c2518ee856fcb1e13943859ca5b77ba71"
+  integrity sha512-lm7wJmlOSmBvHq49zLfs3cghOt9kcRhLezCbuhXQUXhhiaKLCvYuyA1AGId0kiJDPX2SggrU3Ojb+TOcxPEAqw==
+  dependencies:
+    "@joepie91/unreachable" "^1.0.0"
+    "@promistream/propagate-abort" "^0.1.2"
+    bluebird "^3.5.4"
+    p-defer "^3.0.0"
+
+"@validatem/allow-extra-properties@^0.1.0":
+  version "0.1.0"
+  resolved "https://registry.yarnpkg.com/@validatem/allow-extra-properties/-/allow-extra-properties-0.1.0.tgz#e8c434818d6fd74b8cb237cfaa4d548295de13c1"
+  integrity sha512-9jihpYxw1vp4FdjnbN0bTVZMLYv//9OjFNTsVLG5OV4xHESwtgkgQEF5/N5rY1iBwoH/pcKuRl44MBZ8eMdrKw==
+  dependencies:
+    "@validatem/with-context" "^0.1.0"
+
+"@validatem/annotate-errors@^0.1.2":
+  version "0.1.2"
+  resolved "https://registry.yarnpkg.com/@validatem/annotate-errors/-/annotate-errors-0.1.2.tgz#fa9152bb30f4f42b69496b527e38f0c31ff605a9"
+  integrity sha512-EuX7pzdYI/YpTmZcgdPG481Oi3elAg8JWh/LYXuE1h6MaZk3A8eP5DD33/l7EoKzrysn6y8nCsqNa1ngei562w==
+  dependencies:
+    "@validatem/match-validation-error" "^0.1.0"
+
+"@validatem/any-property@^0.1.0":
+  version "0.1.3"
+  resolved "https://registry.yarnpkg.com/@validatem/any-property/-/any-property-0.1.3.tgz#fc7768c1922a8bacff9369ae48913672e5350f52"
+  integrity sha512-jYWxif5ff9pccu7566LIQ/4+snlApXEJUimBywzAriBgS3r4eDBbz3oZFHuiPmhxNK/NNof5YUS+L6Sk3zaMfg==
+  dependencies:
+    "@validatem/annotate-errors" "^0.1.2"
+    "@validatem/combinator" "^0.1.0"
+    "@validatem/error" "^1.0.0"
+    "@validatem/validation-result" "^0.1.1"
+    "@validatem/virtual-property" "^0.1.0"
+    default-value "^1.0.0"
+
+"@validatem/anything@^0.1.0":
+  version "0.1.0"
+  resolved "https://registry.yarnpkg.com/@validatem/anything/-/anything-0.1.0.tgz#09b57720476b9f7ab072c3e5d0a3d4234b721435"
+  integrity sha512-VJcygPpLw2fAhh29m2qL1AybHY7Ewl7xpvVgNIZpqUwMsSZXWSmzmbZhqE4Sr6Wy2n6FbZVzVoUFREO589SPcQ==
+
+"@validatem/array-of@^0.1.2":
+  version "0.1.2"
+  resolved "https://registry.yarnpkg.com/@validatem/array-of/-/array-of-0.1.2.tgz#59c09879fb41c583e45b210e7f7c78fd7f86ac33"
+  integrity sha512-3YjrZOxxlburFfRdJyPWbNoAA7a72E3/2nPCyVGTE8lekQy9NZSyrPjntMozwE14rsnGGLWFLCgNWKu73cyhxQ==
+  dependencies:
+    "@validatem/annotate-errors" "^0.1.2"
+    "@validatem/combinator" "^0.1.0"
+    "@validatem/is-array" "^0.1.0"
+    "@validatem/validation-result" "^0.1.1"
+
+"@validatem/combinator@^0.1.0", "@validatem/combinator@^0.1.1":
+  version "0.1.2"
+  resolved "https://registry.yarnpkg.com/@validatem/combinator/-/combinator-0.1.2.tgz#eab893d55f1643b9c6857eaf6ff7ed2a728e89ff"
+  integrity sha512-vE8t1tNXknmN62FlN6LxQmA2c6TwVKZ+fl/Wit3H2unFdOhu7SZj2kRPGjAXdK/ARh/3svYfUBeD75pea0j1Sw==
+
+"@validatem/core@^0.3.15":
+  version "0.3.15"
+  resolved "https://registry.yarnpkg.com/@validatem/core/-/core-0.3.15.tgz#645a0734dbc6efa3a5c39c62c5f2d8fa773f89f3"
+  integrity sha512-4nBLGzgpPrPsZ5DDXDXwL5p+GUEvpAFt6I3/YUHoah+ckYmKNh9qwmWKkFZHxJVdRrTewGFRj0FPw5fqje1yxA==
+  dependencies:
+    "@validatem/annotate-errors" "^0.1.2"
+    "@validatem/any-property" "^0.1.0"
+    "@validatem/error" "^1.0.0"
+    "@validatem/match-validation-error" "^0.1.0"
+    "@validatem/match-versioned-special" "^0.1.0"
+    "@validatem/match-virtual-property" "^0.1.0"
+    "@validatem/normalize-rules" "^0.1.0"
+    "@validatem/required" "^0.1.0"
+    "@validatem/validation-result" "^0.1.1"
+    "@validatem/virtual-property" "^0.1.0"
+    as-expression "^1.0.0"
+    assure-array "^1.0.0"
+    create-error "^0.3.1"
+    default-value "^1.0.0"
+    execall "^2.0.0"
+    flatten "^1.0.3"
+    indent-string "^4.0.0"
+    is-arguments "^1.0.4"
+    supports-color "^7.1.0"
+    syncpipe "^1.0.0"
+
+"@validatem/error@^1.0.0", "@validatem/error@^1.1.0":
+  version "1.1.0"
+  resolved "https://registry.yarnpkg.com/@validatem/error/-/error-1.1.0.tgz#bef46e7066c39761b494ebe3eec2ecdc7348f4ed"
+  integrity sha512-gZJEoZq1COi/8/5v0fVKQ9uX54x5lb5HbV7mzIOhY6dqjmLNfxdQmpECZPQrCAOpcRkRMJ7zaFhq4UTslpY9yA==
+
+"@validatem/has-shape@^0.1.0":
+  version "0.1.8"
+  resolved "https://registry.yarnpkg.com/@validatem/has-shape/-/has-shape-0.1.8.tgz#dff0f0449c12b96d150091b7a980154d810ae63d"
+  integrity sha512-x2i8toW1uraFF2Vl6WBl4CScbBeg5alrtoCKMyXbJkHf2B5QxL/ftUh2RQRcBzx6U0i7KUb8vdShcWAa+fehRQ==
+  dependencies:
+    "@validatem/annotate-errors" "^0.1.2"
+    "@validatem/combinator" "^0.1.0"
+    "@validatem/error" "^1.0.0"
+    "@validatem/validation-result" "^0.1.1"
+    array-union "^2.1.0"
+    as-expression "^1.0.0"
+    assure-array "^1.0.0"
+    default-value "^1.0.0"
+    flatten "^1.0.3"
+
+"@validatem/is-array@^0.1.0":
+  version "0.1.1"
+  resolved "https://registry.yarnpkg.com/@validatem/is-array/-/is-array-0.1.1.tgz#fbe15ca8c97c30b622a5bbeb536d341e99cfc2c5"
+  integrity sha512-XD3C+Nqfpnbb4oO//Ufodzvui7SsCIW/stxZ39dP/fyRsBHrdERinkFATH5HepegtDlWMQswm5m1XFRbQiP2oQ==
+  dependencies:
+    "@validatem/error" "^1.0.0"
+
+"@validatem/is-plain-object@^0.1.0":
+  version "0.1.1"
+  resolved "https://registry.yarnpkg.com/@validatem/is-plain-object/-/is-plain-object-0.1.1.tgz#b7a3ef8ef960882c7c41e84ed709fa0bfb932e93"
+  integrity sha512-aNGbNIbKRpYI0lRBczlTBbiA+nqN52ADAASdySKg2/QeSCVtYS4uOIeCNIJRAgXe/5sUnLTuL4pgq628uAl7Kw==
+  dependencies:
+    "@validatem/error" "^1.0.0"
+    is-plain-obj "^2.1.0"
+
+"@validatem/match-special@^0.1.0":
+  version "0.1.0"
+  resolved "https://registry.yarnpkg.com/@validatem/match-special/-/match-special-0.1.0.tgz#4e0c28f1aee5bf53c1ef30bbf8c755d4946ae0ff"
+  integrity sha512-TFiq9Wk/1Hoja4PK85WwNYnwBXk3+Lgoj59ZIMxm2an1qmNYp8j+BnSvkKBflba451yIn6V1laU9NJf+/NYZgw==
+
+"@validatem/match-validation-error@^0.1.0":
+  version "0.1.0"
+  resolved "https://registry.yarnpkg.com/@validatem/match-validation-error/-/match-validation-error-0.1.0.tgz#fa87f5f1836e7c1d9bf6b75b2addf0a5b21e4c1e"
+  integrity sha512-6akGTk7DdulOreyqDiGdikwRSixQz/AlvARSX18dcWaTFc79KxCLouL2hyoFcor9IIUhu5RTY4/i756y4T1yxA==
+  dependencies:
+    "@validatem/match-versioned-special" "^0.1.0"
+
+"@validatem/match-versioned-special@^0.1.0":
+  version "0.1.0"
+  resolved "https://registry.yarnpkg.com/@validatem/match-versioned-special/-/match-versioned-special-0.1.0.tgz#2eacc48debecdbbe7e3d02f0c0a665afaea9bedf"
+  integrity sha512-xoOTY0bdA2ELj+ntcDVJ8YyMEFIJpjZ4HNPL9lGcbnRFwJBhQcHUAhUpZwkMxu02zH9wkNM1FvYGHxPz40745Q==
+
+"@validatem/match-virtual-property@^0.1.0":
+  version "0.1.0"
+  resolved "https://registry.yarnpkg.com/@validatem/match-virtual-property/-/match-virtual-property-0.1.0.tgz#4de2de1075987b5f3b356d3f2bcf6c0be5b5fb83"
+  integrity sha512-ssd3coFgwbLuqvZftLZTy3eHN0TFST8oTS2XTViQdXJPXVoJmwEKBpFhXgwnb5Ly1CE037R/KWpjhd1TP/56kQ==
+
+"@validatem/normalize-rules@^0.1.0":
+  version "0.1.3"
+  resolved "https://registry.yarnpkg.com/@validatem/normalize-rules/-/normalize-rules-0.1.3.tgz#59fd6193b1091ff97b5c723b32c9bb1fe2a9dc9c"
+  integrity sha512-HHPceAP2ce9NWymIZrgLCTzpdwXNRBCCB5H6ZPc5ggOrbmh4STpT83fLazleHtvYNlqgXZ4GjQOvCwrjaM+qEA==
+  dependencies:
+    "@validatem/has-shape" "^0.1.0"
+    "@validatem/is-plain-object" "^0.1.0"
+    "@validatem/match-special" "^0.1.0"
+    assure-array "^1.0.0"
+    default-value "^1.0.0"
+    flatten "^1.0.3"
+    is-plain-obj "^2.1.0"
+
+"@validatem/remove-nullish-items@^0.1.0":
+  version "0.1.0"
+  resolved "https://registry.yarnpkg.com/@validatem/remove-nullish-items/-/remove-nullish-items-0.1.0.tgz#fe1a8b64d11276b506fae2bd2c41da4985a5b5ff"
+  integrity sha512-cs4YSF47TA/gHnV5muSUUqGi5PwybP5ztu5SYnPKxQVTyubvcbrFat51nOvJ2PmUasyrIccoYMmATiviXkTi6g==
+
+"@validatem/required@^0.1.0", "@validatem/required@^0.1.1":
+  version "0.1.1"
+  resolved "https://registry.yarnpkg.com/@validatem/required/-/required-0.1.1.tgz#64f4a87333fc5955511634036b7f8948ed269170"
+  integrity sha512-vI4NzLfay4RFAzp7xyU34PHb8sAo6w/3frrNh1EY9Xjnw2zxjY5oaxwmbFP1jVevBE6QQEnKogtzUHz/Zuvh6g==
+
+"@validatem/validation-result@^0.1.1", "@validatem/validation-result@^0.1.2":
+  version "0.1.2"
+  resolved "https://registry.yarnpkg.com/@validatem/validation-result/-/validation-result-0.1.2.tgz#4e75cfd87305fc78f8d05ac84921a2c99a0348e0"
+  integrity sha512-okmP8JarIwIgfpaVcvZGuQ1yOsLKT3Egt49Ynz6h1MAeGsP/bGHXkkXtbiWOVsk5Tzku5vDVFSrFnF+5IEHKxw==
+  dependencies:
+    default-value "^1.0.0"
+
+"@validatem/virtual-property@^0.1.0":
+  version "0.1.0"
+  resolved "https://registry.yarnpkg.com/@validatem/virtual-property/-/virtual-property-0.1.0.tgz#880540dfd149f98ecf1095d93912e34443381fe4"
+  integrity sha512-JUUvWtdqoSkOwlsl20oB3qFHYIL05a/TAfdY4AJcs55QeVTiX5iI1b8IoQW644sIWWooBuLv+XwoxjRsQFczlQ==
+
+"@validatem/with-context@^0.1.0":
+  version "0.1.2"
+  resolved "https://registry.yarnpkg.com/@validatem/with-context/-/with-context-0.1.2.tgz#3645c04897664f70995104961277e07b61b4f615"
+  integrity sha512-noAWf4CsmU+BCz+KOg3GPq9+R9BQLWOQnOgWVfkYHFdLnnbLhl8w/ONdzvFzUYGHIZGKZwsWVCp+Kwz/tAfMnA==
+  dependencies:
+    "@validatem/combinator" "^0.1.1"
+
+"@validatem/wrap-error@^0.3.0":
+  version "0.3.0"
+  resolved "https://registry.yarnpkg.com/@validatem/wrap-error/-/wrap-error-0.3.0.tgz#f8d170e79b6fdd68321d82c60581ad345be7d6b9"
+  integrity sha512-km5v6F/Xm7j8W/tmCmht2BTzxMLSpBUJ5MdhJD7ABEut/fdO0tNca1u1imTnWCULCJcdDHbNtpSmDMvXFg3E7Q==
+  dependencies:
+    "@validatem/combinator" "^0.1.1"
+    "@validatem/error" "^1.0.0"
+    "@validatem/match-validation-error" "^0.1.0"
+    "@validatem/validation-result" "^0.1.2"
+    as-expression "^1.0.0"
+    default-value "^1.0.0"
+    split-filter-n "^1.1.2"
+
+array-union@^2.1.0:
+  version "2.1.0"
+  resolved "https://registry.yarnpkg.com/array-union/-/array-union-2.1.0.tgz#b798420adbeb1de828d84acd8a2e23d3efe85e8d"
+  integrity sha512-HGyxoOTYUyCM6stUe6EJgnd4EoewAI7zMdfqO+kGjnlZmBDz/cR5pf8r/cR4Wq60sL/p0IkcjUEEPwS3GFrIyw==
+
+as-expression@^1.0.0:
+  version "1.0.0"
+  resolved "https://registry.yarnpkg.com/as-expression/-/as-expression-1.0.0.tgz#7bc620ca4cb2fe0ee90d86729bd6add33b8fd831"
+  integrity sha512-Iqh4GxNUfxbJdGn6b7/XMzc8m1Dz2ZHouBQ9DDTzyMRO3VPPIAXeoY/sucRxxxXKbUtzwzWZSN6jPR3zfpYHHA==
+
+assure-array@^1.0.0:
+  version "1.0.0"
+  resolved "https://registry.yarnpkg.com/assure-array/-/assure-array-1.0.0.tgz#4f4ad16a87659d6200a4fb7103462033d216ec1f"
+  integrity sha1-T0rRaodlnWIApPtxA0YgM9IW7B8=
+
+bluebird@^3.5.4:
+  version "3.5.4"
+  resolved "https://registry.yarnpkg.com/bluebird/-/bluebird-3.5.4.tgz#d6cc661595de30d5b3af5fcedd3c0b3ef6ec5714"
+  integrity sha512-FG+nFEZChJrbQ9tIccIfZJBz3J7mLrAhxakAbnrJWn8d7aKOC+LWifa0G+p4ZqKp4y13T7juYvdhq9NzKdsrjw==
+
+call-bind@^1.0.0:
+  version "1.0.2"
+  resolved "https://registry.yarnpkg.com/call-bind/-/call-bind-1.0.2.tgz#b1d4e89e688119c3c9a903ad30abb2f6a919be3c"
+  integrity sha512-7O+FbCihrB5WGbFYesctwmTKae6rOiIzmz1icreWJ+0aA7LJfuqhEso2T9ncpcFtzMQtzXf2QGGueWJGTYsqrA==
+  dependencies:
+    function-bind "^1.1.1"
+    get-intrinsic "^1.0.2"
+
+clone-regexp@^2.1.0:
+  version "2.2.0"
+  resolved "https://registry.yarnpkg.com/clone-regexp/-/clone-regexp-2.2.0.tgz#7d65e00885cd8796405c35a737e7a86b7429e36f"
+  integrity sha512-beMpP7BOtTipFuW8hrJvREQ2DrRu3BE7by0ZpibtfBA+qfHYvMGTc2Yb1JMYPKg/JUw0CHYvpg796aNTSW9z7Q==
+  dependencies:
+    is-regexp "^2.0.0"
+
+create-error@^0.3.1:
+  version "0.3.1"
+  resolved "https://registry.yarnpkg.com/create-error/-/create-error-0.3.1.tgz#69810245a629e654432bf04377360003a5351a23"
+  integrity sha1-aYECRaYp5lRDK/BDdzYAA6U1GiM=
+
+debug@^4.1.1:
+  version "4.1.1"
+  resolved "https://registry.yarnpkg.com/debug/-/debug-4.1.1.tgz#3b72260255109c6b589cee050f1d516139664791"
+  integrity sha512-pYAIzeRo8J6KPEaJ0VWOh5Pzkbw/RetuzehGM7QRRX5he4fPHx2rdKMB256ehJCkX+XRQm16eZLqLNS8RSZXZw==
+  dependencies:
+    ms "^2.1.1"
+
+default-value@^1.0.0:
+  version "1.0.0"
+  resolved "https://registry.yarnpkg.com/default-value/-/default-value-1.0.0.tgz#8c6f52a5a1193fe78fdc9f86eb71d16c9757c83a"
+  integrity sha1-jG9SpaEZP+eP3J+G63HRbJdXyDo=
+  dependencies:
+    es6-promise-try "0.0.1"
+
+es6-promise-try@0.0.1:
+  version "0.0.1"
+  resolved "https://registry.yarnpkg.com/es6-promise-try/-/es6-promise-try-0.0.1.tgz#10f140dad27459cef949973e5d21a087f7274b20"
+  integrity sha1-EPFA2tJ0Wc75SZc+XSGgh/cnSyA=
+
+execall@^2.0.0:
+  version "2.0.0"
+  resolved "https://registry.yarnpkg.com/execall/-/execall-2.0.0.tgz#16a06b5fe5099df7d00be5d9c06eecded1663b45"
+  integrity sha512-0FU2hZ5Hh6iQnarpRtQurM/aAvp3RIbfvgLHrcqJYzhXyV2KFruhuChf9NC6waAhiUR7FFtlugkI4p7f2Fqlow==
+  dependencies:
+    clone-regexp "^2.1.0"
+
+flatten@^1.0.3:
+  version "1.0.3"
+  resolved "https://registry.yarnpkg.com/flatten/-/flatten-1.0.3.tgz#c1283ac9f27b368abc1e36d1ff7b04501a30356b"
+  integrity sha512-dVsPA/UwQ8+2uoFe5GHtiBMu48dWLTdsuEd7CKGlZlD78r1TTWBvDuFaFGKCo/ZfEr95Uk56vZoX86OsHkUeIg==
+
+function-bind@^1.1.1:
+  version "1.1.1"
+  resolved "https://registry.yarnpkg.com/function-bind/-/function-bind-1.1.1.tgz#a56899d3ea3c9bab874bb9773b7c5ede92f4895d"
+  integrity sha512-yIovAzMX49sF8Yl58fSCWJ5svSLuaibPxXQJFLmBObTuCr0Mf1KiPopGM9NiFjiYBCbfaa2Fh6breQ6ANVTI0A==
+
+get-intrinsic@^1.0.2:
+  version "1.1.1"
+  resolved "https://registry.yarnpkg.com/get-intrinsic/-/get-intrinsic-1.1.1.tgz#15f59f376f855c446963948f0d24cd3637b4abc6"
+  integrity sha512-kWZrnVM42QCiEA2Ig1bG8zjoIMOgxWwYCEeNdwY6Tv/cOSeGpcoX4pXHfKUxNKVoArnrEr2e9srnAxxGIraS9Q==
+  dependencies:
+    function-bind "^1.1.1"
+    has "^1.0.3"
+    has-symbols "^1.0.1"
+
+has-flag@^4.0.0:
+  version "4.0.0"
+  resolved "https://registry.yarnpkg.com/has-flag/-/has-flag-4.0.0.tgz#944771fd9c81c81265c4d6941860da06bb59479b"
+  integrity sha512-EykJT/Q1KjTWctppgIAgfSO0tKVuZUjhgMr17kqTumMl6Afv3EISleU7qZUzoXDFTAHTDC4NOoG/ZxU3EvlMPQ==
+
+has-symbols@^1.0.1:
+  version "1.0.2"
+  resolved "https://registry.yarnpkg.com/has-symbols/-/has-symbols-1.0.2.tgz#165d3070c00309752a1236a479331e3ac56f1423"
+  integrity sha512-chXa79rL/UC2KlX17jo3vRGz0azaWEx5tGqZg5pO3NUyEJVB17dMruQlzCCOfUvElghKcm5194+BCRvi2Rv/Gw==
+
+has@^1.0.3:
+  version "1.0.3"
+  resolved "https://registry.yarnpkg.com/has/-/has-1.0.3.tgz#722d7cbfc1f6aa8241f16dd814e011e1f41e8796"
+  integrity sha512-f2dvO0VU6Oej7RkWJGrehjbzMAjFp5/VKPp5tTpWIV4JHHZK1/BxbFRtf/siA2SWTe09caDmVtYYzWEIbBS4zw==
+  dependencies:
+    function-bind "^1.1.1"
+
+indent-string@^4.0.0:
+  version "4.0.0"
+  resolved "https://registry.yarnpkg.com/indent-string/-/indent-string-4.0.0.tgz#624f8f4497d619b2d9768531d58f4122854d7251"
+  integrity sha512-EdDDZu4A2OyIK7Lr/2zG+w5jmbuk1DVBnEwREQvBzspBJkCEbRa8GxU1lghYcaGJCnRWibjDXlq779X1/y5xwg==
+
+is-arguments@^1.0.4:
+  version "1.1.0"
+  resolved "https://registry.yarnpkg.com/is-arguments/-/is-arguments-1.1.0.tgz#62353031dfbee07ceb34656a6bde59efecae8dd9"
+  integrity sha512-1Ij4lOMPl/xB5kBDn7I+b2ttPMKa8szhEIrXDuXQD/oe3HJLTLhqhgGspwgyGd6MOywBUqVvYicF72lkgDnIHg==
+  dependencies:
+    call-bind "^1.0.0"
+
+is-plain-obj@^2.1.0:
+  version "2.1.0"
+  resolved "https://registry.yarnpkg.com/is-plain-obj/-/is-plain-obj-2.1.0.tgz#45e42e37fccf1f40da8e5f76ee21515840c09287"
+  integrity sha512-YWnfyRwxL/+SsrWYfOpUtz5b3YD+nyfkHvjbcanzk8zgyO4ASD67uVMRt8k5bM4lLMDnXfriRhOpemw+NfT1eA==
+
+is-regexp@^2.0.0:
+  version "2.1.0"
+  resolved "https://registry.yarnpkg.com/is-regexp/-/is-regexp-2.1.0.tgz#cd734a56864e23b956bf4e7c66c396a4c0b22c2d"
+  integrity sha512-OZ4IlER3zmRIoB9AqNhEggVxqIH4ofDns5nRrPS6yQxXE1TPCUpFznBfRQmQa8uC+pXqjMnukiJBxCisIxiLGA==
+
+ms@^2.1.1:
+  version "2.1.1"
+  resolved "https://registry.yarnpkg.com/ms/-/ms-2.1.1.tgz#30a5864eb3ebb0a66f2ebe6d727af06a09d86e0a"
+  integrity sha512-tgp+dl5cGk28utYktBsrFqA7HKgrhgPsg6Z/EfhWI4gl1Hwq8B/GmY/0oXZ6nF8hDVesS/FpnYaD/kOWhYQvyg==
+
+p-defer@^3.0.0:
+  version "3.0.0"
+  resolved "https://registry.yarnpkg.com/p-defer/-/p-defer-3.0.0.tgz#d1dceb4ee9b2b604b1d94ffec83760175d4e6f83"
+  integrity sha512-ugZxsxmtTln604yeYd29EGrNhazN2lywetzpKhfmQjW/VJmhpDmWbiX+h0zL8V91R0UXkhb3KtPmyq9PZw3aYw==
+
+split-filter-n@^1.1.2:
+  version "1.1.2"
+  resolved "https://registry.yarnpkg.com/split-filter-n/-/split-filter-n-1.1.2.tgz#268be1ec9c4d93dfb27b030c06165ac1b6f70f66"
+  integrity sha512-+hXSQYpKe1uyXPXI4zQtAJAlaF2EzEc+BaF2goMeNL5oUD5YLqrVcpjxELJxpomXfwMCUaYLAszEbdY9gKVdHQ==
+
+supports-color@^7.1.0:
+  version "7.2.0"
+  resolved "https://registry.yarnpkg.com/supports-color/-/supports-color-7.2.0.tgz#1b7dcdcb32b8138801b3e478ba6a51caa89648da"
+  integrity sha512-qpCAvRl9stuOHveKsn7HncJRvv501qIacKzQlO/+Lwxc9+0q2wLyv4Dfvt80/DPn2pqOBsJdDiogXGR9+OvwRw==
+  dependencies:
+    has-flag "^4.0.0"
+
+syncpipe@^1.0.0:
+  version "1.0.0"
+  resolved "https://registry.yarnpkg.com/syncpipe/-/syncpipe-1.0.0.tgz#170340f813150bc8fcb8878b1b9c71ea0ccd3727"
+  integrity sha512-cdiAFTnFJRvUaNPDc2n9CqoFvtIL3+JUMJZrC3kA3FzpugHOqu0TvkgNwmnxPZ5/WjAzMcfMS3xm+AO7rg/j/w==
+  dependencies:
+    assure-array "^1.0.0"