X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2Fthread-worker.ts;h=639fd19c8437fdb478aeea0ebc481bc9125f019b;hb=79aafe9fe0d0c4c40da43337b0a8c358f5f834ce;hp=4ed85c297e46836f867ac8e3bf3d9f3a60b42741;hpb=4f3c3d894171421375559b43ce469bd5ccb475da;p=poolifier.git diff --git a/src/worker/thread-worker.ts b/src/worker/thread-worker.ts index 4ed85c29..639fd19c 100644 --- a/src/worker/thread-worker.ts +++ b/src/worker/thread-worker.ts @@ -1,7 +1,6 @@ -import type { MessagePort } from 'worker_threads' -import { isMainThread, parentPort } from 'worker_threads' +import type { MessagePort } from 'node:worker_threads' +import { isMainThread, parentPort } from 'node:worker_threads' import type { MessageValue } from '../utility-types' -import { EMPTY_OBJECT_LITERAL } from '../utils' import { AbstractWorker } from './abstract-worker' import type { WorkerOptions } from './worker-options' @@ -29,10 +28,7 @@ export class ThreadWorker< * @param fn - Function processed by the worker when the pool's `execution` function is invoked. * @param opts - Options for the worker. */ - public constructor ( - fn: (data: Data) => Response, - opts: WorkerOptions = EMPTY_OBJECT_LITERAL - ) { + public constructor (fn: (data: Data) => Response, opts: WorkerOptions = {}) { super('worker-thread-pool:poolifier', isMainThread, fn, parentPort, opts) }