add prebuilt web worker

package.json

@@ -1,7 +1,7 @@
 {
   "name": "workerpool",
   "license": "Apache-2.0",
-  "version": "9.1.0",
+  "version": "9.1.1",
   "description": "Offload tasks to a pool of workers on node.js and in the browser",
   "homepage": "https://github.com/josdejong/workerpool",
   "author": "Jos de Jong <wjosdejong@gmail.com> (https://github.com/josdejong)",

src/Pool.js

@@ -34,6 +34,8 @@ function Pool(script, options) {
   /** @readonly */
   this.workerOpts = Object.freeze(options.workerOpts || {});
   /** @readonly */
+  this.webWorker = options.webWorker || null;
+  /** @readonly */
   this.workerThreadOpts = Object.freeze(options.workerThreadOpts || {})
   /** @private */
   this.debugPortStart = (options.debugPortStart || 43210);
@@ -430,6 +432,7 @@ Pool.prototype._createWorkerHandler = function () {
     workerType: this.workerType,
     workerTerminateTimeout: this.workerTerminateTimeout,
     emitStdStreams: this.emitStdStreams,
+    webWorker: this.webWorker
   });
 }
 

src/WorkerHandler.js

@@ -64,7 +64,7 @@ function getDefaultWorker() {
 function setupWorker(script, options) {
   if (options.workerType === 'web') { // browser only
     ensureWebWorker();
-    return setupBrowserWorker(script, options.workerOpts, Worker);
+    return setupBrowserWorker(script, options.workerOpts, Worker, options.webWorker);
   } else if (options.workerType === 'thread') { // node.js only
     WorkerThreads = ensureWorkerThreads();
     return setupWorkerThreadWorker(script, WorkerThreads, options);
@@ -73,7 +73,7 @@ function setupWorker(script, options) {
   } else { // options.workerType === 'auto' or undefined
     if (environment.platform === 'browser') {
       ensureWebWorker();
-      return setupBrowserWorker(script, options.workerOpts, Worker);
+      return setupBrowserWorker(script, options.workerOpts, Worker, options.webWorker);
     }
     else { // environment.platform === 'node'
       var WorkerThreads = tryRequireWorkerThreads();
@@ -86,12 +86,11 @@ function setupWorker(script, options) {
   }
 }
 
-function setupBrowserWorker(script, workerOpts, Worker) {
+function setupBrowserWorker(script, workerOpts, Worker, existingWorker) {
   // validate the options right before creating the worker (not when creating the pool)
   validateOptions(workerOpts, workerOptsNames, 'workerOpts')
-
   // create the web worker
-  var worker = new Worker(script, workerOpts);
+  var worker = existingWorker || new Worker(script, workerOpts);
 
   worker.isBrowserWorker = true;
   // add node.js API to the web worker

src/types.js

@@ -21,6 +21,7 @@
  * @property {string[]} [forkArgs] For `process` worker type. An array passed as `args` to [child_process.fork](https://nodejs.org/api/child_process.html#child_processforkmodulepath-args-options)
  * @property {import('child_process').ForkOptions} [forkOpts] For `process` worker type. An object passed as `options` to [child_process.fork](https://nodejs.org/api/child_process.html#child_processforkmodulepath-args-options).
  * @property {WorkerOptions} [workerOpts] For `web` worker type. An object passed to the [constructor of the web worker](https://html.spec.whatwg.org/multipage/workers.html#dom-worker). See [WorkerOptions specification](https://html.spec.whatwg.org/multipage/workers.html#workeroptions) for available options.
+ * @property {Worker} [webWorker] For `web` worker type. An allocated `Worker` object.
  * @property {import('worker_threads').WorkerOptions} [workerThreadOpts] Object`. For `worker` worker type. An object passed to [worker_threads.options](https://nodejs.org/api/worker_threads.html#new-workerfilename-options).
  * @property {boolean} [emitStdStreams] Capture stdout and stderr from the worker and emit them via the `stdout` and `stderr` events. Not supported by the `web` worker type.
  * @property { (arg: WorkerArg) => WorkerArg | undefined } [onCreateWorker] A callback that is called whenever a worker is being created. It can be used to allocate resources for each worker for example. Optionally, this callback can return an object containing one or more of the `WorkerArg` properties. The provided properties will be used to override the Pool properties for the worker being created.