Merge branch 'master' of github.com:poolifier/poolifier
[poolifier.git] / tests / worker / abstract-worker.test.js
index 02042620ea0a0bd4f57d41912de49e79829c37bf..bf3dc28e6874cdf91f4714eee90bac11f4de75af 100644 (file)
@@ -2,7 +2,7 @@ const { expect } = require('expect')
 const { ClusterWorker, KillBehaviors, ThreadWorker } = require('../../lib')
 
 describe('Abstract worker test suite', () => {
-  class StubPoolWithIsMainWorker extends ThreadWorker {
+  class StubWorkerWithMainWorker extends ThreadWorker {
     constructor (fn, opts) {
       super(fn, opts)
       this.mainWorker = undefined
@@ -105,15 +105,18 @@ describe('Abstract worker test suite', () => {
     expect(typeof worker.taskFunctions.get('fn2') === 'function').toBe(true)
   })
 
-  it('Verify that handleError() method is working properly', () => {
-    const error = new Error('My error')
-    const worker = new ThreadWorker(() => {})
-    expect(worker.handleError(error)).toStrictEqual(error)
+  it('Verify that handleError() method works properly', () => {
+    const error = new Error('Error as an error')
+    const worker = new ClusterWorker(() => {})
+    expect(worker.handleError(error)).not.toBeInstanceOf(Error)
+    expect(worker.handleError(error)).toStrictEqual(error.message)
+    const errorMessage = 'Error as a string'
+    expect(worker.handleError(errorMessage)).toStrictEqual(errorMessage)
   })
 
   it('Verify that getMainWorker() throw error if main worker is not set', () => {
     expect(() =>
-      new StubPoolWithIsMainWorker(() => {}).getMainWorker()
-    ).toThrowError('Main worker was not set')
+      new StubWorkerWithMainWorker(() => {}).getMainWorker()
+    ).toThrowError('Main worker not set')
   })
 })