ng-web-apis / workers / 10

pending completion

Build # 10

Build Type

Pull #1

travis-ci-com

Committed by

web-flow

Commit Message

<a href="https://github.com/ng-web-apis/workers/commit/<a class=hub.com/ng-web-apis/workers/commit/60933257a42e39cd189444a67ef42a5ce7b5cc86">60933257a<a href="https://github.com/ng-web-apis/workers/commit/60933257a42e39cd189444a67ef42a5ce7b5cc86">">Merge </a><a class="double-link" href="https://github.com/ng-web-apis/workers/commit/<a class="double-link" href="https://github.com/ng-web-apis/workers/commit/c9be2fb55976d03524c07328508302ffdd66713b">c9be2fb55</a>">c9be2fb55</a><a href="https://github.com/ng-web-apis/workers/commit/60933257a42e39cd189444a67ef42a5ce7b5cc86"> into bd0b18e7f">bd0b18e7f</a>

Pull Request Pull Request #1: feat: added service and base classes

Run Details

7 of 12 branches covered (58.33%)

Branch coverage included in aggregate %.

54 of 54 new or added lines in 5 files covered. (100.0%)

51 of 57 relevant lines covered (89.47%)

3.33 hits per line

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

73.17

/projects/workers/src/worker/classes/web-worker.ts

import {fromEvent} from 'rxjs';
import {takeWhile} from 'rxjs/operators';
import {WorkerFunction} from '../types/worker-function';
import {AnyNextSubject} from './any-next-subject';

export class WebWorker<T = any, R = any> extends AnyNextSubject<R> {
    private worker!: Worker;

    constructor(private url: string, options?: WorkerOptions) {
        super();

        try {
            this.worker = new Worker(url, options);
        } catch (e) {
            this.error(e);
        }

        fromEvent<MessageEvent>(this.worker, 'message')
            .pipe(takeWhile(() => !this.isStopped))
            .subscribe(event => {
                if (event.data) {
                    if (event.data.hasOwnProperty('error')) {
                        this.error(event.data.error);
                    } else if (event.data.hasOwnProperty('result')) {
                        super.next(event.data.result);
                    } else {
                        super.next();
                    }
                }
            });

        fromEvent<ErrorEvent>(this.worker, 'error')
            .pipe(takeWhile(() => !this.isStopped))
            .subscribe(event => {
                this.error(event.error);
            });
    }

    public static fromFunction<T, R>(
        fn: WorkerFunction<T, R>,
        options?: WorkerOptions,
    ): WebWorker<T, R> {
        return new WebWorker<T, R>(WebWorker.createFnUrl(fn), options);
    }

    private static createFnUrl(fn: WorkerFunction): string {
        const script = `
(function(fn){
    function isFunction(type){
        return type === 'function';
    }

    self.addEventListener('message', function(e) {
        var result = fn.call(null, e.data);
        if(result && [typeof result.then, typeof result.catch].every(isFunction)){
            result.then(function(res){
                postMessage({result: res});
            }).catch(function(error){
                postMessage({error: error});
            })
        } else {
            postMessage({result: result});
        }
    })
})(${fn.toString()});
        `;

        const blob = new Blob([script], {type: 'text/javascript'});

        return URL.createObjectURL(blob);
    }

    complete() {
        this.worker.terminate();
        URL.revokeObjectURL(this.url);
        super.complete();
    }

    next(value?: T) {
        if (!this.isStopped) {
            this.worker.postMessage(value);
        }
    }
}

1	import {fromEvent} from 'rxjs';
2	import {takeWhile} from 'rxjs/operators';
3	import {WorkerFunction} from '../types/worker-function';
4	import {AnyNextSubject} from './any-next-subject';
5
6	export class WebWorker<T = any, R = any> extends AnyNextSubject<R> {	1✔
7	private worker!: Worker;
8
9	constructor(private url: string, options?: WorkerOptions) {	8✔
10	super();	8!
11
12	try {	8✔
13	this.worker = new Worker(url, options);	8✔
14	} catch (e) {
15	this.error(e);	×
16	}
17
18	fromEvent<MessageEvent>(this.worker, 'message')	8✔
19	.pipe(takeWhile(() => !this.isStopped))	7✔
20	.subscribe(event => {
21	if (event.data) {	7!
22	if (event.data.hasOwnProperty('error')) {	7!
23	this.error(event.data.error);	×
24	} else if (event.data.hasOwnProperty('result')) {	7!
25	super.next(event.data.result);	7✔
26	} else {
27	super.next();	×
28	}
29	}
30	});
31
32	fromEvent<ErrorEvent>(this.worker, 'error')	8✔
33	.pipe(takeWhile(() => !this.isStopped))	1✔
34	.subscribe(event => {
35	this.error(event.error);	1✔
36	});
37	}
38
39	public static fromFunction<T, R>(	1✔
40	fn: WorkerFunction<T, R>,
41	options?: WorkerOptions,
42	): WebWorker<T, R> {
43	return new WebWorker<T, R>(WebWorker.createFnUrl(fn), options);	7✔
44	}
45
46	private static createFnUrl(fn: WorkerFunction): string {	1✔
47	const script = `	7✔
48	(function(fn){
49	function isFunction(type){
50	return type === 'function';
51	}
52
53	self.addEventListener('message', function(e) {
54	var result = fn.call(null, e.data);
55	if(result && [typeof result.then, typeof result.catch].every(isFunction)){
56	result.then(function(res){
57	postMessage({result: res});
58	}).catch(function(error){
59	postMessage({error: error});
60	})
61	} else {
62	postMessage({result: result});
63	}
64	})
65	})(${fn.toString()});
66	`;
67
68	const blob = new Blob([script], {type: 'text/javascript'});	7✔
69
70	return URL.createObjectURL(blob);	7✔
71	}
72
73	complete() {	1✔
74	this.worker.terminate();	×
75	URL.revokeObjectURL(this.url);	×
76	super.complete();	×
77	}
78
79	next(value?: T) {	1✔
80	if (!this.isStopped) {	7!
81	this.worker.postMessage(value);	7✔
82	}
83	}
84	}	1✔

ng-web-apis / workers / 10

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