Function createLimiter

src/background/utils/network.ts:169–207

()

}

function createLimiter() {
    const loadingUrls = new Set<string>();
    const awaitingUrls = new Map<string, Set<(response: FileLoaderResponse) => void>>();

    function loading(url: string) {
        const result = loadingUrls.has(url);
        loadingUrls.add(url);
        return result;
    }

    async function wait(url: string) {
        return new Promise<FileLoaderResponse>((resolve) => {
            if (!awaitingUrls.has(url)) {
                awaitingUrls.set(url, new Set());
            }
            awaitingUrls.get(url)?.add(resolve);
        });
    }

    async function loaded(url: string, data: string) {
        loadingUrls.delete(url);
        if (awaitingUrls.has(url)) {
            const response = {data};
            awaitingUrls.get(url)!.forEach((callback) => callback(response));
            awaitingUrls.delete(url);
        }
    }

    async function failed(url: string, error: Error) {
        loadingUrls.delete(url);
        if (awaitingUrls.has(url)) {
            const response = {error};
            awaitingUrls.get(url)!.forEach((callback) => callback(response));
            awaitingUrls.delete(url);
        }
    }

    return {loading, wait, loaded, failed};
}

export interface FetchRequestParameters {
    url: string;