// Hardcoded module "node:timers/promises" // https://github.com/niksy/isomorphic-timers-promises/blob/master/index.js const 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"; } } function validateObject(object, name) { if (object === null || typeof object !== "object") { throw new ERR_INVALID_ARG_TYPE(name, "Object", object); } } function validateBoolean(value, name) { if (typeof value !== "boolean") { throw new ERR_INVALID_ARG_TYPE(name, "boolean", value); } } function validateAbortSignal(signal, name) { if (typeof signal !== "undefined" && (signal === null || typeof signal !== "object" || !("aborted" in signal))) { throw new ERR_INVALID_ARG_TYPE(name, "AbortSignal", signal); } } function asyncIterator({ next: nextFunction, return: returnFunction }) { const result = {}; if (typeof nextFunction === "function") { result.next = nextFunction; } if (typeof returnFunction === "function") { result.return = returnFunction; } result[symbolAsyncIterator] = function () { return this; }; return result; } function setTimeoutPromise(after = 1, value, options = {}) { const arguments_ = [].concat(value ?? []); try { validateObject(options, "options"); } catch (error) { return Promise.reject(error); } const { signal, ref: reference = true } = 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; } function setImmediatePromise(value, options = {}) { try { validateObject(options, "options"); } catch (error) { return Promise.reject(error); } const { signal, ref: reference = true } = 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; } function setIntervalPromise(after = 1, value, options = {}) { /* eslint-disable no-undefined, no-unreachable-loop, no-loop-func */ try { validateObject(options, "options"); } catch (error) { return asyncIterator({ next: function () { return Promise.reject(error); }, }); } const { signal, ref: reference = true } = 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; let callback; interval = setInterval(() => { notYielded++; if (callback) { callback(); callback = undefined; } }, after); if (!reference) { interval?.unref?.(); } if (signal) { onCancel = () => { clearInterval(interval); if (callback) { callback(); callback = undefined; } }; 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) { notYielded = notYielded - 1; return { done: false, value: value }; } return { done: true }; }); }, return: function () { clearInterval(interval); signal?.removeEventListener("abort", onCancel); return Promise.resolve({}); }, }); } catch (error) { return asyncIterator({ next: function () { clearInterval(interval); signal?.removeEventListener("abort", onCancel); }, }); } } export default { setTimeout: setTimeoutPromise, setImmediate: setImmediatePromise, setInterval: setIntervalPromise, scheduler: { wait: (delay, options) => setTimeoutPromise(delay, undefined, options), yield: setImmediatePromise, }, }; orkspace-packages'>jarred/bundle-workspace-packages Unnamed repository; edit this file 'description' to name the repository.
aboutsummaryrefslogtreecommitdiff
path: root/integration/bunjs-only-snippets/exit.js (unfollow)
AgeCommit message (Expand)AuthorFilesLines
2022-05-11Update README.mdbun-v0.0.82Gravatar Jarred Sumner 1-2/+6
2022-05-11Update build-idGravatar Jarred Sumner 1-1/+1
2022-05-11Fix several bugs in napiGravatar Jarred Sumner 3-22/+54
2022-05-11Make the napi mjs file runnable in both bun & nodeGravatar Jarred Sumner 1-7/+6
2022-05-11Update build-idbun-v0.0.81Gravatar Jarred Sumner 1-1/+1
2022-05-11disable the new target allowed errorGravatar Jarred Sumner 1-4/+5
2022-05-11Update Makefilebun-v0.0.80Gravatar Jarred Sumner 1-0/+1
2022-05-11Update MakefileGravatar Jarred Sumner 1-1/+1
2022-05-11Fix export symbols on LinuxGravatar Jarred Sumner 4-25/+153
2022-05-11Add test for import.meta.requireGravatar Jarred Sumner 2-1/+11
2022-05-11[napi] Add a couple more symbolsGravatar Jarred Sumner 1-0/+2
2022-05-11[napi] Fix panic inside napi_fatal_errorGravatar Jarred Sumner 1-11/+18
2022-05-11[napi] Stub a couple moreGravatar Jarred Sumner 3-6/+52
2022-05-11[bun.js] eagerly convert to import.meta.requireGravatar Jarred Sumner 2-3/+24
2022-05-11[json] Fix bug with negative integers in json parserGravatar Jarred Sumner 1-3/+6
2022-05-11[bun.js] Implement a polyfill for the `detect-libc` npm packageGravatar Jarred Sumner 2-0/+53
2022-05-11[bun.js] Implement `import.meta.require`Gravatar Jarred Sumner 13-158/+539
2022-05-11[bun.js] Implement `import.meta.resolveSync`Gravatar Jarred Sumner 3-1/+78
2022-05-10Include napi in plus100Gravatar Jarred Sumner 1-4/+20
2022-05-10Add test for Buffer.byteLengthGravatar Jarred Sumner 1-0/+7
2022-05-10[napi] Error on import .nodeGravatar Jarred Sumner 1-29/+1
2022-05-10Update napi.cppGravatar Jarred Sumner 1-1/+0
2022-05-10[napi] Fix string bugGravatar Jarred Sumner 4-58/+125
2022-05-10[napi] transpile require(*.node) into process.dlopenGravatar Jarred Sumner 4-3/+30
2022-05-10[bun.js] Implement `Buffer.byteLength`Gravatar Jarred Sumner 7-47/+443
2022-05-09Fix extra quote in bundled require errorsGravatar Jarred Sumner 1-2/+2
2022-05-09few more napi functionsGravatar Jarred Sumner 2-1/+30
2022-05-09Update MakefileGravatar Jarred Sumner 1-3/+3
2022-05-09Update Dockerfile.baseGravatar Jarred Sumner 1-1/+1
2022-05-09[napi] getters & setters workGravatar Jarred Sumner 1-26/+39