-
Notifications
You must be signed in to change notification settings - Fork 24
Expand file tree
/
Copy pathasync.ts
More file actions
40 lines (32 loc) · 1001 Bytes
/
async.ts
File metadata and controls
40 lines (32 loc) · 1001 Bytes
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
// compat/runtime/async.ts
// Async utilities - replacement for std/async/deferred.ts
export interface Deferred<T> extends Promise<T> {
resolve(value: T | PromiseLike<T>): void;
reject(reason?: unknown): void;
readonly state: "pending" | "fulfilled" | "rejected";
}
export function deferred<T>(): Deferred<T> {
let methods: {
resolve: (value: T | PromiseLike<T>) => void;
reject: (reason?: unknown) => void;
};
let state: "pending" | "fulfilled" | "rejected" = "pending";
const promise = new Promise<T>((resolve, reject) => {
methods = {
resolve: (value) => {
state = "fulfilled";
resolve(value);
},
reject: (reason) => {
state = "rejected";
reject(reason);
},
};
}) as Deferred<T>;
Object.defineProperty(promise, "state", {
get: () => state,
});
return Object.assign(promise, methods!);
}
export const delay = (ms: number): Promise<void> =>
new Promise((resolve) => setTimeout(resolve, ms));