11191716771

Committed 05 Oct 2024 08:14AM UTC coverage: 79.958%. First build

Build # 11191716771

Build Type

Pull #466

github

Committed by

web-flow

Commit Message

Merge 6e6a72fe8 into cf5d16f16

Pull Request Pull Request #466: Dev2

Run Details

135 of 194 branches covered (69.59%)

Branch coverage included in aggregate %.

187 of 208 new or added lines in 5 files covered. (89.9%)

1393 of 1717 relevant lines covered (81.13%)

19.67 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

87.88

/utils/queue.ts

export function createTaskQueue() {
    // deno-lint-ignore no-explicit-any
    const array: any = [];

    let isExecuting = false;
    async function exec() {
        while (array.length > 0) {
            const { fn, args, resolve } = array.shift();
            try {
                const result = await fn(...args);
                resolve(result);
            } catch (error) {
                console.error("Error executing function:", error);
            }
        }
        isExecuting = false;
    }

    // deno-lint-ignore no-explicit-any
    function process<T extends any[], R>(
        fn: (...args: T) => Promise<R> | R,
        ...args: T
    ): Promise<R> {
        return new Promise((resolve) => {
            array.push({ fn, args, resolve });
            if (!isExecuting) {
                isExecuting = true;
                exec();
            }
        });
    }

    return { process: process };
}

1	export function createTaskQueue() {	5✔
2	// deno-lint-ignore no-explicit-any	28✔
3	const array: any = [];	28✔
4
5	let isExecuting = false;	28✔
6	async function exec() {	28✔
7	while (array.length > 0) {	39✔
8	const { fn, args, resolve } = array.shift();	52✔
9	try {	52✔
10	const result = await fn(...args);	52✔
11	resolve(result);	52✔
NEW 12	} catch (error) {	×
NEW 13	console.error("Error executing function:", error);	×
NEW 14	}	×
15	}	52✔
16	isExecuting = false;	39✔
17	}	39✔
18
19	// deno-lint-ignore no-explicit-any	28✔
20	function process<T extends any[], R>(	28✔
21	fn: (...args: T) => Promise<R> \| R,	28✔
22	...args: T	28✔
23	): Promise<R> {
24	return new Promise((resolve) => {	41✔
25	array.push({ fn, args, resolve });	270✔
26	if (!isExecuting) {	54✔
27	isExecuting = true;	65✔
28	exec();	65✔
29	}	65✔
30	});	41✔
31	}	41✔
32
33	return { process: process };	84✔
34	}	28✔

fastrodev / fastro / 11191716771

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous