push.rocks/smartpromise
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(core): update

Browse Source
This commit is contained in:
Philipp Kunz 2022-02-27 21:02:27 +01:00
parent 1848006601
commit 4c3565c618
1 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
ts/index.ts
View File

@ -84,15 +84,23 @@ export const map = async <T>(inputArg: T[], functionArg: IAsyncFunction<T>) => {
return resultArray; return resultArray;
}; };
export const timeoutWrap = <T = any>(promiseArg: Promise<T>, timeoutInMs: number) => { export const timeoutWrap = async <T = any>(promiseArg: Promise<T>, timeoutInMsArg: number, rejectArg = true) => {
return new Promise<T>((resolve, reject) => { return new Promise<T>((resolve, reject) => {
setTimeout(() => { setTimeout(() => {
if (rejectArg) {
reject(new Error('timeout')); reject(new Error('timeout'));
}, timeoutInMs); } else {
resolve(null);
}
}, timeoutInMsArg);
promiseArg.then(resolve, reject); promiseArg.then(resolve, reject);
}); });
}; };
export const timeoutAndContinue = async <T = any>(promiseArg: Promise<T>, timeoutInMsArg = 60000) => {
return timeoutWrap(promiseArg, timeoutInMsArg, false);
}
export const getFirstTrueOrFalse = async (promisesArg: Promise<boolean>[]) => { export const getFirstTrueOrFalse = async (promisesArg: Promise<boolean>[]) => {
const done = defer<boolean>(); const done = defer<boolean>();
for (const promiseArg of promisesArg) { for (const promiseArg of promisesArg) {