ng-web-apis / workers / 6

pending completion

Build # 6

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/e44c855e1186bbeb92f3fa11f0656f048b340fed">e44c855e1<a href="https://github.com/ng-web-apis/workers/commit/e44c855e1186bbeb92f3fa11f0656f048b340fed">">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/e257eb56815930443976714fba9823f6747c8622">e257eb568</a>">e257eb568</a><a href="https://github.com/ng-web-apis/workers/commit/e44c855e1186bbeb92f3fa11f0656f048b340fed"> into bd0b18e7f">bd0b18e7f</a>

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

Run Details

5 of 12 branches covered (41.67%)

Branch coverage included in aggregate %.

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

47 of 57 relevant lines covered (82.46%)

1.44 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 = `
self.addEventListener('message', function(e) {
    var result = ((${fn.toString()}).call(null, e.data));
    if(result && [typeof result.then, typeof result.catch].every(function (type) {return type === 'function'})){
        result.then(function(res){
            postMessage({result: res});
        }).catch(function(error){
            postMessage({error: error});
        })
    } else {
        postMessage({result: result});
    }
});
        `;

        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) {	4✔
10	super();	4!
11
12	try {	4✔
13	this.worker = new Worker(url, options);	4✔
14	} catch (e) {
15	this.error(e);	×
16	}
17
18	fromEvent<MessageEvent>(this.worker, 'message')	4✔
19	.pipe(takeWhile(() => !this.isStopped))	2✔
20	.subscribe(event => {
21	if (event.data) {	2!
22	if (event.data.hasOwnProperty('error')) {	2!
23	this.error(event.data.error);	×
24	} else if (event.data.hasOwnProperty('result')) {	2!
25	super.next(event.data.result);	2✔
26	} else {
27	super.next();	×
28	}
29	}
30	});
31
32	fromEvent<ErrorEvent>(this.worker, 'error')	4✔
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);	3✔
44	}
45
46	private static createFnUrl(fn: WorkerFunction): string {	1✔
47	const script = `	3✔
48	self.addEventListener('message', function(e) {
49	var result = ((${fn.toString()}).call(null, e.data));
50	if(result && [typeof result.then, typeof result.catch].every(function (type) {return type === 'function'})){
51	result.then(function(res){
52	postMessage({result: res});
53	}).catch(function(error){
54	postMessage({error: error});
55	})
56	} else {
57	postMessage({result: result});
58	}
59	});
60	`;
61
62	const blob = new Blob([script], {type: 'text/javascript'});	3✔
63
64	return URL.createObjectURL(blob);	3✔
65	}
66
67	complete() {	1✔
68	this.worker.terminate();	×
69	URL.revokeObjectURL(this.url);	×
70	super.complete();	×
71	}
72
73	next(value?: T) {	1✔
74	if (!this.isStopped) {	2!
75	this.worker.postMessage(value);	2✔
76	}
77	}
78	}	1✔

ng-web-apis / workers / 6

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