CHEVALLIER Abel
42 lines
1.1 KiB
TypeScript
42 lines
1.1 KiB
TypeScript
interface AbortSignalEventTargetAddOptions {
|
|
once: boolean;
|
|
}
|
|
|
|
export interface AbortSignalEventTarget {
|
|
addEventListener: (
|
|
name: 'abort',
|
|
listener: () => void,
|
|
options?: AbortSignalEventTargetAddOptions
|
|
) => void;
|
|
removeEventListener: (name: 'abort', listener: () => void) => void;
|
|
aborted?: boolean;
|
|
reason?: unknown;
|
|
}
|
|
|
|
export interface AbortSignalEventEmitter {
|
|
off: (name: 'abort', listener: () => void) => void;
|
|
once: (name: 'abort', listener: () => void) => void;
|
|
}
|
|
|
|
export type AbortSignalAny = AbortSignalEventTarget | AbortSignalEventEmitter;
|
|
|
|
export class AbortError extends Error {
|
|
constructor (reason?: AbortSignalEventTarget['reason']) {
|
|
// TS does not recognizes the cause clause
|
|
// @ts-expect-error
|
|
super('The task has been aborted', { cause: reason });
|
|
}
|
|
|
|
get name () {
|
|
return 'AbortError';
|
|
}
|
|
}
|
|
|
|
export function onabort (abortSignal: AbortSignalAny, listener: () => void) {
|
|
if ('addEventListener' in abortSignal) {
|
|
abortSignal.addEventListener('abort', listener, { once: true });
|
|
} else {
|
|
abortSignal.once('abort', listener);
|
|
}
|
|
}
|