lint

examples/messages/index.js

@@ -9,7 +9,7 @@ const piscina = new Piscina({
 
 (async function () {
   piscina.on('message', (event) => {
-      console.log("Messsage received from worker: ", event);
+    console.log('Messsage received from worker: ', event);
   });
 
   await piscina.run();

examples/messages/worker.js

@@ -1,6 +1,6 @@
 'use strict';
-const { parentPort } = require('worker_threads')
+const { parentPort } = require('worker_threads');
 
 module.exports = () => {
-    parentPort.postMessage('hello from the worker pool');
+  parentPort.postMessage('hello from the worker pool');
 };

src/index.ts

@@ -616,7 +616,7 @@ class ThreadPool {
       pool._processPendingMessages();
     }
 
-    function onReady() {
+    function onReady () {
       if (workerInfo.currentUsage() === 0) {
         workerInfo.unref();
       }
@@ -626,7 +626,7 @@ class ThreadPool {
       }
     }
 
-    function onEventMessage(message: any) {
+    function onEventMessage (message: any) {
       pool.publicInterface.emit('message', message);
     }
 

test/messages.ts

@@ -4,16 +4,16 @@ import { resolve } from 'path';
 import { once } from 'events';
 
 test('Pool receive message from workers', async ({ equal }) => {
-    const pool = new Piscina({
-      filename: resolve(__dirname, 'fixtures/eval.js')
-    });
+  const pool = new Piscina({
+    filename: resolve(__dirname, 'fixtures/eval.js')
+  });
 
-    const messagePromise = once(pool, 'message');
+  const messagePromise = once(pool, 'message');
 
-    const taskResult = pool.runTask(`
+  const taskResult = pool.runTask(`
         require('worker_threads').parentPort.postMessage("some message");
         42
     `);
-    equal(await taskResult, 42);
-    equal((await messagePromise)[0], 'some message');
-  });
+  equal(await taskResult, 42);
+  equal((await messagePromise)[0], 'some message');
+});