#13125

Committed 01 Oct 2024 02:12PM UTC coverage: 86.842% (-1.4%) from 88.193%

Build Type

push

Committed by

Commit Message

Merge d4a9e5fff into 3a2dc7282

Run Details

11554 of 14068 branches covered (82.13%)

Branch coverage included in aggregate %.

7000 of 7592 new or added lines in 100 files covered. (92.2%)

83 existing lines in 18 files now uncovered.

12701 of 13862 relevant lines covered (91.62%)

29529.09 hits per line

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

83.33

/src/ActionPipeline.ts

import { Deferred } from './deferred';

/**
 * Enforces that a single action can be running at a time
 */
export class ActionPipeline {
    private workQueue: Array<Work<any>> = [];

    public run<T extends Action<any>, R extends Awaited<PromiseLike<ReturnType<T>>>>(action: T): Promise<R> {
        const work = {
            action: action,
            deferred: new Deferred<any>()
        };
        this.workQueue.push(work);
        this.process();
        return work.deferred.promise;
    }

    private process() {
        //if we're already processing,
        if (this.isProcessing) {
            return;
        }
        while (this.workQueue.length > 0) {
            const work = this.workQueue.shift();
            try {
                const result = Promise.resolve(
                    work.action()
                );
                work.deferred.resolve(result);
            } catch (e) {
                work.deferred.reject(e);
            }
        }
    }
    private isProcessing = false;
}

interface Work<T> {
    action: Action<T>;
    deferred: Deferred<T>;
}

export type Action<T> = () => T | PromiseLike<T>;

1	import { Deferred } from './deferred';	1✔
2
3	/**
4	* Enforces that a single action can be running at a time
5	*/
6	export class ActionPipeline {	1✔
7	private workQueue: Array<Work<any>> = [];	3,482✔
8
9	public run<T extends Action<any>, R extends Awaited<PromiseLike<ReturnType<T>>>>(action: T): Promise<R> {
10	const work = {	640✔
11	action: action,
12	deferred: new Deferred<any>()
13	};
14	this.workQueue.push(work);	640✔
15	this.process();	640✔
16	return work.deferred.promise;	640✔
17	}
18
19	private process() {
20	//if we're already processing,
21	if (this.isProcessing) {	640!
NEW 22	return;	×
23	}
24	while (this.workQueue.length > 0) {	640✔
25	const work = this.workQueue.shift();	640✔
26	try {	640✔
27	const result = Promise.resolve(	640✔
28	work.action()
29	);
30	work.deferred.resolve(result);	640✔
31	} catch (e) {
NEW 32	work.deferred.reject(e);	×
33	}
34	}
35	}
36	private isProcessing = false;	3,482✔
37	}
38
39	interface Work<T> {
40	action: Action<T>;
41	deferred: Deferred<T>;
42	}
43
44	export type Action<T> = () => T \| PromiseLike<T>;

rokucommunity / brighterscript / #13125

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