WPoll

Worker poll use worker_threads

Example

• main.ts

import { WPoll } from 'wpoll';
import path from 'path';

let wpoll = new WPoll<number>(path.resolve(__dirname, './worker.js'));
wpoll.init();

(async () => {
    console.log(await wpoll.exec(100));
})();

• worker.ts

import { WWorker } from 'wpoll';

new WWorker(async (message) => {
    console.log(message);
    return 5;
});

Types

WPoll<T = void, P = void>

Name	Parameter	Type	Description
Constructor		WPoll<T, P>
	workerFile	string	Path to worker file (absolute path preferred)
	props	WPollProps	Init Parameters
init	-	-	Init Workers. Must be called once
exec	T	P	Execute with parameters T and return P

WWorker<T = void, P = void>

Name	Parameter	Type	Description
Constructor		WWorker<T,P>
	onMessage	(message: T) => Promise<P> | P	callback on message received