chore: run lint fix
authorEmanuele Stoppa <my.burning@gmail.com>
Fri, 8 Sep 2023 12:10:05 +0000 (13:10 +0100)
committerEmanuele Stoppa <my.burning@gmail.com>
Fri, 8 Sep 2023 12:10:05 +0000 (13:10 +0100)
benchmarks/versus-external-pools/dynamic-worker-nodes.js
benchmarks/versus-external-pools/fixed-worker-nodes.js
examples/typescript/pool.ts
src/pools/thread/fixed.ts
src/pools/worker-node.ts
src/worker/abstract-worker.ts

index cdac7274ef993831e67d797edff731d09ae096af..74b113c3e54425362e55bece9f3933d3d17ec358 100644 (file)
@@ -28,7 +28,7 @@ async function run () {
   // eslint-disable-next-line n/no-process-exit
   process.exit()
 }
-;(async () => {
+(async () => {
   try {
     await run()
   } catch (e) {
index 9400840088e33e201d4526929606a9d3133a814d..e65e988892d511262a3881381758f062bd678a55 100644 (file)
@@ -28,7 +28,7 @@ async function run () {
   // eslint-disable-next-line n/no-process-exit
   process.exit()
 }
-;(async () => {
+(async () => {
   try {
     await run()
   } catch (e) {
index 93774422b4500459715ec236c136c1601f13add4..ab6d4f268b38a76520cf15b919948eae3e9eb924 100644 (file)
@@ -1,11 +1,11 @@
 import { dirname, extname, join } from 'path'
 import { fileURLToPath } from 'url'
-import type { MyData, MyResponse } from './worker'
 import {
   DynamicThreadPool,
   FixedThreadPool,
   availableParallelism
 } from 'poolifier'
+import type { MyData, MyResponse } from './worker'
 
 const workerFile = join(
   dirname(fileURLToPath(import.meta.url)),
index 9acfd6400ef59a12823b52899ca7f35e2ae96e56..d69055cf0909efa3b9cf45983163e0be6a35c513 100644 (file)
@@ -82,7 +82,7 @@ export class FixedThreadPool<
     message: MessageValue<Data>,
     transferList?: TransferListItem[]
   ): void {
-    ;(
+    (
       this.workerNodes[workerNodeKey].messageChannel as MessageChannel
     ).port1.postMessage(message, transferList)
   }
@@ -108,7 +108,7 @@ export class FixedThreadPool<
     workerNodeKey: number,
     listener: (message: MessageValue<Message>) => void
   ): void {
-    ;(
+    (
       this.workerNodes[workerNodeKey].messageChannel as MessageChannel
     ).port1.on('message', listener)
   }
index dd116dfb2ca656d06188916cd7924193e57a8c16..ca275dedab806b9a4cc2c9c6aee5d3cf550b99f5 100644 (file)
@@ -169,7 +169,7 @@ implements IWorkerNode<Worker, Data> {
       this.onEmptyQueueCount = 0
       return
     }
-    ;(this.onEmptyQueue as WorkerNodeEventCallback)(this.info.id as number)
+    (this.onEmptyQueue as WorkerNodeEventCallback)(this.info.id as number)
     ++this.onEmptyQueueCount
     await sleep(exponentialDelay(this.onEmptyQueueCount))
     await this.startOnEmptyQueue()
index a0d78dbd08f2023e38cd37dbff6dbc74064168fb..ca14133f2dafa7b1d6692f84459bafabb431e935 100644 (file)
@@ -351,7 +351,7 @@ export abstract class AbstractWorker<
   protected handleKillMessage (message: MessageValue<Data>): void {
     this.stopCheckActive()
     if (isAsyncFunction(this.opts.killHandler)) {
-      ;(this.opts.killHandler?.() as Promise<void>)
+      (this.opts.killHandler?.() as Promise<void>)
         .then(() => {
           this.sendToMainWorker({ kill: 'success', workerId: this.id })
           return null