import EventTarget from '../event/EventTarget.js'; import * as PropertySymbol from '../PropertySymbol.js'; import Event from '../event/Event.js'; import DOMExceptionNameEnum from '../exception/DOMExceptionNameEnum.js'; /** * AbortSignal. * * @see https://developer.mozilla.org/en-US/docs/Web/API/AbortSignal */ export default class AbortSignal extends EventTarget { // Public properties aborted = false; reason = null; // Events onabort = null; /** * Constructor. */ constructor() { super(); if (!this[PropertySymbol.window]) { throw new TypeError(`Failed to construct '${this.constructor.name}': '${this.constructor.name}' was constructed outside a Window context.`); } } /** * Return a default description for the AbortSignal class. */ get [Symbol.toStringTag]() { return 'AbortSignal'; } /** * Aborts the signal. * * @param [reason] Reason. */ [PropertySymbol.abort](reason) { if (this.aborted) { return; } this.reason = reason || new this[PropertySymbol.window].DOMException('signal is aborted without reason', DOMExceptionNameEnum.abortError); this.aborted = true; this.dispatchEvent(new Event('abort')); } /** * Throws an "AbortError" if the signal has been aborted. */ throwIfAborted() { if (this.aborted) { throw this.reason; } } /** * Returns an AbortSignal instance that has been set as aborted. * * @param [reason] Reason. * @returns AbortSignal instance. */ static abort(reason) { const signal = new this(); signal.reason = reason || new this[PropertySymbol.window].DOMException('signal is aborted without reason', DOMExceptionNameEnum.abortError); signal.aborted = true; return signal; } /** * Returns an AbortSignal that will automatically abort after a specified * time. * * @param [time] Time in milliseconds. * @returns AbortSignal instance. */ static timeout(time) { const window = this[PropertySymbol.window]; const signal = new this(); window.setTimeout(() => { signal[PropertySymbol.abort](new window.DOMException('signal timed out', DOMExceptionNameEnum.timeoutError)); }, time); return signal; } /** * Takes an iterable of abort signals and returns an AbortSignal that is * aborted when any of the input iterable abort signals are aborted. * * The abort reason will be set to the reason of the first signal that is * aborted. If any of the given abort signals are already aborted then so will * be the returned AbortSignal. * * @param [signals] Iterable of abort signals. * @returns AbortSignal instance. */ static any(signals) { for (const signal of signals) { if (signal.aborted) { return this.abort(signal.reason); } } const anySignal = new this(); const handlers = new Map(); const stopListening = () => { for (const signal of signals) { signal.removeEventListener('abort', handlers.get(signal)); } }; for (const signal of signals) { const handler = () => { stopListening(); anySignal[PropertySymbol.abort](signal.reason); }; handlers.set(signal, handler); signal.addEventListener('abort', handler); } return anySignal; } } //# sourceMappingURL=AbortSignal.js.map