(ms: number, options: DelayOptions = {})
| 49 | * ``` |
| 50 | */ |
| 51 | export function delay(ms: number, options: DelayOptions = {}): Promise<void> { |
| 52 | const { signal, persistent = true } = options; |
| 53 | if (signal?.aborted) return Promise.reject(signal.reason); |
| 54 | return new Promise((resolve, reject) => { |
| 55 | const abort = () => { |
| 56 | clearTimeout(+i); |
| 57 | reject(signal?.reason); |
| 58 | }; |
| 59 | const done = () => { |
| 60 | signal?.removeEventListener("abort", abort); |
| 61 | resolve(); |
| 62 | }; |
| 63 | const i = setArbitraryLengthTimeout(done, ms); |
| 64 | signal?.addEventListener("abort", abort, { once: true }); |
| 65 | if (persistent === false) { |
| 66 | try { |
| 67 | Deno.unrefTimer(+i); |
| 68 | } catch (error) { |
| 69 | if (!(error instanceof ReferenceError)) { |
| 70 | clearTimeout(+i); |
| 71 | throw error; |
| 72 | } |
| 73 | // deno-lint-ignore no-console |
| 74 | console.error("`persistent` option is only available in Deno"); |
| 75 | } |
| 76 | } |
| 77 | }); |
| 78 | } |
| 79 | |
| 80 | const I32_MAX = 2 ** 31 - 1; |
| 81 |
no test coverage detected