X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Fworker%2Fthread-worker.test.js;h=c08adffd9816a9c0f4bd78337b857a664fa4553f;hb=refs%2Ftags%2Fv2.6.10;hp=dfe49655f10c7380604dd2edcfad5d30e030bf98;hpb=74a2a19445618440f22537123650c01d065ae358;p=poolifier.git diff --git a/tests/worker/thread-worker.test.js b/tests/worker/thread-worker.test.js index dfe49655..c08adffd 100644 --- a/tests/worker/thread-worker.test.js +++ b/tests/worker/thread-worker.test.js @@ -1,24 +1,31 @@ -const expect = require('expect') +const { expect } = require('expect') const { ThreadWorker } = require('../../lib') -let numberOfMessagesPosted = 0 -const postMessage = function (message) { - numberOfMessagesPosted++ - console.log(message) -} -class SpyWorker extends ThreadWorker { - getMainWorker () { - return { postMessage: postMessage } +describe('Thread worker test suite', () => { + let numberOfMessagesPosted = 0 + const postMessage = function () { + ++numberOfMessagesPosted + } + class SpyWorker extends ThreadWorker { + getMainWorker () { + return { postMessage } + } } -} -describe('Thread worker test suite', () => { it('Verify worker has default maxInactiveTime', () => { const worker = new ThreadWorker(() => {}) - expect(worker.maxInactiveTime).toEqual(60_000) + expect(worker.opts.maxInactiveTime).toStrictEqual(60000) + }) + + it('Verify that handleError() method is working properly', () => { + const error = new Error('Error as an error') + const worker = new ThreadWorker(() => {}) + expect(worker.handleError(error)).toStrictEqual(error) + const errorMessage = 'Error as a string' + expect(worker.handleError(errorMessage)).toStrictEqual(errorMessage) }) - it('Verify worker invoke the getMainWorker and postMessage methods', () => { + it('Verify worker invokes the getMainWorker() and postMessage() methods', () => { const worker = new SpyWorker(() => {}) worker.sendToMainWorker({ ok: 1 }) expect(numberOfMessagesPosted).toBe(1)