aboutsummaryrefslogtreecommitdiff
path: root/src/js/out/modules_dev/node/timers.promises.js
diff options
context:
space:
mode:
Diffstat (limited to 'src/js/out/modules_dev/node/timers.promises.js')
-rw-r--r--src/js/out/modules_dev/node/timers.promises.js182
1 files changed, 0 insertions, 182 deletions
diff --git a/src/js/out/modules_dev/node/timers.promises.js b/src/js/out/modules_dev/node/timers.promises.js
deleted file mode 100644
index 39ec4904a..000000000
--- a/src/js/out/modules_dev/node/timers.promises.js
+++ /dev/null
@@ -1,182 +0,0 @@
-var validateObject = function(object, name) {
- if (object === null || typeof object !== "object")
- throw new ERR_INVALID_ARG_TYPE(name, "Object", object);
-}, validateBoolean = function(value, name) {
- if (typeof value !== "boolean")
- throw new ERR_INVALID_ARG_TYPE(name, "boolean", value);
-}, validateAbortSignal = function(signal, name) {
- if (typeof signal !== "undefined" && (signal === null || typeof signal !== "object" || !("aborted" in signal)))
- throw new ERR_INVALID_ARG_TYPE(name, "AbortSignal", signal);
-}, asyncIterator = function({ next: nextFunction, return: returnFunction }) {
- const result = {};
- if (typeof nextFunction === "function")
- result.next = nextFunction;
- if (typeof returnFunction === "function")
- result.return = returnFunction;
- return result[symbolAsyncIterator] = function() {
- return this;
- }, result;
-}, setTimeoutPromise = function(after = 1, value, options = {}) {
- const arguments_ = [].concat(value ?? []);
- try {
- validateObject(options, "options");
- } catch (error) {
- return Promise.reject(error);
- }
- const { signal, ref: reference = !0 } = options;
- try {
- validateAbortSignal(signal, "options.signal");
- } catch (error) {
- return Promise.reject(error);
- }
- try {
- validateBoolean(reference, "options.ref");
- } catch (error) {
- return Promise.reject(error);
- }
- if (signal?.aborted)
- return Promise.reject(new AbortError);
- let onCancel;
- const returnValue = new Promise((resolve, reject) => {
- const timeout = setTimeout(() => resolve(value), after, ...arguments_);
- if (!reference)
- timeout?.unref?.();
- if (signal)
- onCancel = () => {
- clearTimeout(timeout), reject(new AbortError);
- }, signal.addEventListener("abort", onCancel);
- });
- if (typeof onCancel !== "undefined")
- returnValue.finally(() => signal.removeEventListener("abort", onCancel));
- return returnValue;
-}, setImmediatePromise = function(value, options = {}) {
- try {
- validateObject(options, "options");
- } catch (error) {
- return Promise.reject(error);
- }
- const { signal, ref: reference = !0 } = options;
- try {
- validateAbortSignal(signal, "options.signal");
- } catch (error) {
- return Promise.reject(error);
- }
- try {
- validateBoolean(reference, "options.ref");
- } catch (error) {
- return Promise.reject(error);
- }
- if (signal?.aborted)
- return Promise.reject(new AbortError);
- let onCancel;
- const returnValue = new Promise((resolve, reject) => {
- const immediate = setImmediate(() => resolve(value));
- if (!reference)
- immediate?.unref?.();
- if (signal)
- onCancel = () => {
- clearImmediate(immediate), reject(new AbortError);
- }, signal.addEventListener("abort", onCancel);
- });
- if (typeof onCancel !== "undefined")
- returnValue.finally(() => signal.removeEventListener("abort", onCancel));
- return returnValue;
-}, setIntervalPromise = function(after = 1, value, options = {}) {
- try {
- validateObject(options, "options");
- } catch (error) {
- return asyncIterator({
- next: function() {
- return Promise.reject(error);
- }
- });
- }
- const { signal, ref: reference = !0 } = options;
- try {
- validateAbortSignal(signal, "options.signal");
- } catch (error) {
- return asyncIterator({
- next: function() {
- return Promise.reject(error);
- }
- });
- }
- try {
- validateBoolean(reference, "options.ref");
- } catch (error) {
- return asyncIterator({
- next: function() {
- return Promise.reject(error);
- }
- });
- }
- if (signal?.aborted)
- return asyncIterator({
- next: function() {
- return Promise.reject(new AbortError);
- }
- });
- let onCancel, interval;
- try {
- let notYielded = 0, callback;
- if (interval = setInterval(() => {
- if (notYielded++, callback)
- callback(), callback = void 0;
- }, after), !reference)
- interval?.unref?.();
- if (signal)
- onCancel = () => {
- if (clearInterval(interval), callback)
- callback(), callback = void 0;
- }, signal.addEventListener("abort", onCancel);
- return asyncIterator({
- next: function() {
- return new Promise((resolve, reject) => {
- if (!signal?.aborted)
- if (notYielded === 0)
- callback = resolve;
- else
- resolve();
- else if (notYielded === 0)
- reject(new AbortError);
- else
- resolve();
- }).then(() => {
- if (notYielded > 0)
- return notYielded = notYielded - 1, { done: !1, value };
- return { done: !0 };
- });
- },
- return: function() {
- return clearInterval(interval), signal?.removeEventListener("abort", onCancel), Promise.resolve({});
- }
- });
- } catch (error) {
- return asyncIterator({
- next: function() {
- clearInterval(interval), signal?.removeEventListener("abort", onCancel);
- }
- });
- }
-}, symbolAsyncIterator = Symbol.asyncIterator;
-
-class ERR_INVALID_ARG_TYPE extends Error {
- constructor(name, expected, actual) {
- super(`${name} must be ${expected}, ${typeof actual} given`);
- this.code = "ERR_INVALID_ARG_TYPE";
- }
-}
-
-class AbortError extends Error {
- constructor() {
- super("The operation was aborted");
- this.code = "ABORT_ERR";
- }
-}
-export {
- setTimeoutPromise as setTimeout,
- setIntervalPromise as setInterval,
- setImmediatePromise as setImmediate
-};
-
-//# debugId=5DCC48B4316389FF64756e2164756e21