diff --git a/dist/restore/index.js b/dist/restore/index.js index 7b7c1e7..745dccb 100644 --- a/dist/restore/index.js +++ b/dist/restore/index.js @@ -79604,7 +79604,7 @@ Object.defineProperty(exports, "__esModule", ({ value: true })); function once(emitter, name, { signal } = {}) { return new Promise((resolve, reject) => { function cleanup() { - signal === null || signal === void 0 ? void 0 : signal.removeEventListener('abort', cleanup); + signal === null || signal === void 0 ? void 0 : signal.removeEventListener('abort', onAbort); emitter.removeListener(name, onEvent); emitter.removeListener('error', onError); } @@ -79616,7 +79616,17 @@ function once(emitter, name, { signal } = {}) { cleanup(); reject(err); } - signal === null || signal === void 0 ? void 0 : signal.addEventListener('abort', cleanup); + function onAbort() { + cleanup(); + const err = new Error('The operation was aborted'); + err.name = 'AbortError'; + reject(err); + } + if (signal === null || signal === void 0 ? void 0 : signal.aborted) { + onAbort(); + return; + } + signal === null || signal === void 0 ? void 0 : signal.addEventListener('abort', onAbort); emitter.on(name, onEvent); emitter.on('error', onError); }); diff --git a/dist/save/index.js b/dist/save/index.js index 92e8763..0fdc45b 100644 --- a/dist/save/index.js +++ b/dist/save/index.js @@ -79604,7 +79604,7 @@ Object.defineProperty(exports, "__esModule", ({ value: true })); function once(emitter, name, { signal } = {}) { return new Promise((resolve, reject) => { function cleanup() { - signal === null || signal === void 0 ? void 0 : signal.removeEventListener('abort', cleanup); + signal === null || signal === void 0 ? void 0 : signal.removeEventListener('abort', onAbort); emitter.removeListener(name, onEvent); emitter.removeListener('error', onError); } @@ -79616,7 +79616,17 @@ function once(emitter, name, { signal } = {}) { cleanup(); reject(err); } - signal === null || signal === void 0 ? void 0 : signal.addEventListener('abort', cleanup); + function onAbort() { + cleanup(); + const err = new Error('The operation was aborted'); + err.name = 'AbortError'; + reject(err); + } + if (signal === null || signal === void 0 ? void 0 : signal.aborted) { + onAbort(); + return; + } + signal === null || signal === void 0 ? void 0 : signal.addEventListener('abort', onAbort); emitter.on(name, onEvent); emitter.on('error', onError); }); diff --git a/package-lock.json b/package-lock.json index ed83cbc..4bfea1c 100644 --- a/package-lock.json +++ b/package-lock.json @@ -849,9 +849,9 @@ } }, "node_modules/@tootallnate/once": { - "version": "2.0.0", - "resolved": "https://registry.npmjs.org/@tootallnate/once/-/once-2.0.0.tgz", - "integrity": "sha512-XCuKFP5PS55gnMVu3dty8KPatLqUoy/ZYzDzAGCQ8JNFCkLXzmI7vNHCR+XpbZaMWQK/vQubr7PkYq8g470J/A==", + "version": "2.0.1", + "resolved": "https://registry.npmjs.org/@tootallnate/once/-/once-2.0.1.tgz", + "integrity": "sha512-HqmEUIGRJ5fSXchkVgR5F7qn48bDBzv0kWj/Kfu5e6uci4UlEeng4331LnBkWffb++Ei3FOVLxo8JJWMFBDMeQ==", "license": "MIT", "engines": { "node": ">= 10"