mirror of
https://github.com/CommunityOx/ox_lib.git
synced 2026-08-17 06:56:03 +01:00
feat(package): add waitFor and sleep functions
This commit is contained in:
@@ -6,3 +6,35 @@ export type FlattenObjectKeys<T extends Record<string, unknown>, Key = keyof T>
|
||||
? `${Key}.${FlattenObjectKeys<T[Key]>}`
|
||||
: `${Key}`
|
||||
: never;
|
||||
|
||||
export function sleep(ms: number) {
|
||||
return new Promise((resolve) => setTimeout(resolve, ms, null));
|
||||
}
|
||||
|
||||
export async function waitFor<T>(cb: () => T, errMessage: string | void, timeout = 1000): Promise<T> {
|
||||
let value = await cb();
|
||||
|
||||
if (value !== undefined) return value;
|
||||
|
||||
if (IsDuplicityVersion()) timeout /= 50;
|
||||
else timeout -= GetFrameTime() * 1000;
|
||||
|
||||
const start = GetGameTimer();
|
||||
let id: number;
|
||||
let i = 0;
|
||||
|
||||
const p = new Promise<T>((resolve, reject) => {
|
||||
id = setTick(async () => {
|
||||
i++;
|
||||
|
||||
if (i > timeout)
|
||||
return reject(`${errMessage || 'failed to resolve callback'} (waited ${(GetGameTimer() - start) / 1000}ms)`);
|
||||
|
||||
value = await cb();
|
||||
|
||||
if (value !== undefined) resolve(value);
|
||||
});
|
||||
}).finally(() => clearTick(id));
|
||||
|
||||
return p;
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user